import threading, queue, time

# The worker thread gets jobs off the queue. When the queue is empty, it

# assumes there will be no more work and exits.

# (Realistically workers will run until terminated.)

def worker():

print('Running worker')

time.sleep(0.1)

while True:

try:

arg = q.get(block=False)

except queue.Empty:

print('Worker', threading.currentThread(), end=' ')

print('queue empty')

break

else:

print('Worker', threading.currentThread(), end=' ')

print('running with argument', arg)

time.sleep(5)

# Create queue

q = queue.Queue()

# Start a pool of 5 workers

for i in range(5):

t = threading.Thread(target=worker, name='worker %i' % (i+1))

t.start()

# Begin adding work to the queue

for i in range(15):

q.put(i)

# Give threads time to run

print('Main thread sleeping')

time.sleep(5)