Parcourir la source

[fix]queue get block=False

jhao il y a 7 ans
Parent
commit
bcf38be2dc
1 fichiers modifiés avec 2 ajouts et 2 suppressions
  1. 2 2
      Schedule/ProxyCheck.py

+ 2 - 2
Schedule/ProxyCheck.py

@@ -40,9 +40,9 @@ class ProxyCheck(ProxyManager, Thread):
 
     def run(self):
         self.db.changeTable(self.useful_proxy_queue)
-        while self.queue.qsize():
+        while True:
             try:
-                proxy = self.queue.get()
+                proxy = self.queue.get(block=False)
             except Empty:
                 break
             count = self.item_dict[proxy]