30 lines
613 B
Python
30 lines
613 B
Python
import threading
|
|
import queue
|
|
import time
|
|
|
|
q = queue.Queue()
|
|
|
|
# def worker():
|
|
# while True:
|
|
# item = q.get()
|
|
# print(f'Working on {item}')
|
|
# time.sleep(1)
|
|
# print(f'Finished {item}')
|
|
# time.sleep(1)
|
|
# q.task_done()
|
|
#
|
|
# # Turn-on the worker thread.
|
|
# threading.Thread(target=worker, daemon=True).start()
|
|
#
|
|
# Send thirty task requests to the worker.
|
|
for item in range(30):
|
|
print(f'Working on {item}')
|
|
time.sleep(1)
|
|
print(f'Finished {item}')
|
|
time.sleep(1)
|
|
# q.put(item)
|
|
|
|
# Block until all tasks are done.
|
|
# q.join()
|
|
print('All work completed')
|