queue based threadings

queue_threading.py

import queue
import threading

NUM_THREADS = 10

def worker(channel):
        while True:
                value = channel.get()
                if value is False:
                        break
                print('value = %d' % value)
                channel.task_done()

channel = queue.Queue()

print("start workers")
workers = []
for val in range(NUM_THREADS):
        th = threading.Thread(target=worker, args=(channel,))
        th.start()
        workers.append(th)

for input in range(100):
        channel.put(input)

channel.join()

for i in range(NUM_THREADS):
        channel.put(False)
for t in workers: t.join()