thread and queue python code example
Example 1: python get item from queue
"""put and get items from queue"""
>>> from Queue import Queue
>>> q = Queue()
>>> q.put(1)
>>> q.put(2)
>>> q.put(3)
>>> print list(q.queue)
[1, 2, 3]
>>> q.get()
1
>>> print list(q.queue)
[2, 3]
Example 2: python threading queue
import threading, queue
q = queue.Queue()
def worker():
while True:
item = q.get()
print(f'Working on {item}')
print(f'Finished {item}')
q.task_done()
threading.Thread(target=worker, daemon=True).start()
for item in range(30):
q.put(item)
print('All task requests sent\n', end='')
q.join()
print('All work completed')