from multiprocessing import JoinableQueue

from threading import Thread

def worker(q):

	while True:

		try:

			item = q.get()

			print(item)

			if item % 5 == 0:

				if item == 5:

					time.sleep(20)

				q.put(111)

			q.task_done()

		except Exception as e:

			print(e)

q = JoinableQueue()

import time

def customer(q):

	for i in range(100):

		try:

			q.put(i)

		except Exception as e:

			print(e)

ct = Thread(target=customer, name='customer', args=(q,))

ct.daemon = True

ct.start()

ct.join()

for i in range(4):

	t = Thread(target=worker, name='worker'+str(i), args=(q,))

	t.daemon = True

	t.start()

q.join()

print('end')