fix wait
This commit is contained in:
@@ -28,7 +28,7 @@ class ProducerThread(threading.Thread):
|
|||||||
q.put(self.threads[i])
|
q.put(self.threads[i])
|
||||||
i += 1
|
i += 1
|
||||||
while q.qsize() > 0:
|
while q.qsize() > 0:
|
||||||
time.sleep(1)
|
time.sleep(0.1)
|
||||||
except:
|
except:
|
||||||
pass
|
pass
|
||||||
not_finished = False
|
not_finished = False
|
||||||
|
|||||||
@@ -12,7 +12,7 @@ import thread
|
|||||||
import basic_producer_consumer
|
import basic_producer_consumer
|
||||||
|
|
||||||
console = Console(highlight=False)
|
console = Console(highlight=False)
|
||||||
VERSION = "1.3.1"
|
VERSION = "1.3.2"
|
||||||
thread.console = console
|
thread.console = console
|
||||||
|
|
||||||
def main():
|
def main():
|
||||||
|
|||||||
Reference in New Issue
Block a user