dev

plot/refill/WriterConsumer.py

@@ -18,18 +18,18 @@ class WriterConsumer(Thread):
         while True:
             size = self._messages.qsize()
             log.debug("%s messages size=%d", self._name, size)
-            if size < self._max_threshold:
-                time.sleep(1)
-            else:
-                self._batch()
+            # if size < self._max_threshold:
+            #     time.sleep(1)
+            # else:
+            #     self._batch()
+            #
+            # if self._stopped:
+            #     self._batch()
 
-            if self._stopped:
+            if size > self._max_threshold:
                 self._batch()
-
-            # if size > self._max_threshold:
-            #     self._batch()
-            # else:
-            #     self._single()
+            else:
+                self._single()
 
             if self._stopped and self._messages.empty():
                 break