diff --git a/queue/abstract/driver/fifottl.lua b/queue/abstract/driver/fifottl.lua
index e57d9ced..496a324c 100644
--- a/queue/abstract/driver/fifottl.lua
+++ b/queue/abstract/driver/fifottl.lua
@@ -144,6 +144,7 @@ local function fifottl_fiber_iteration(self, processed)
     if estimated > 0 or processed > 1000 then
         -- free refcounter
         estimated = estimated > 0 and estimated or 0
+        processed = 0
         self.cond:wait(estimated)
     end
 
diff --git a/queue/abstract/driver/utubettl.lua b/queue/abstract/driver/utubettl.lua
index c2522e88..e2c887dd 100644
--- a/queue/abstract/driver/utubettl.lua
+++ b/queue/abstract/driver/utubettl.lua
@@ -152,6 +152,7 @@ local function utubettl_fiber_iteration(self, processed)
         -- free refcounter
         estimated = processed > 1000 and 0 or estimated
         estimated = estimated > 0 and estimated or 0
+        processed = 0
         self.cond:wait(estimated)
     end