Threading and queues in Python

threading_queues.py

import threading, Queue, time, random

WORKERS = 4
JOB_COUNT = 100

class Worker(threading.Thread):
    def __init__(self, queue):
        self.__queue = queue
        threading.Thread.__init__(self)
        
    def run(self):
        while 1:
            item = self.__queue.get()
            if item is None:
                break # reached end of queue
                
            # pretend we're doing something that takes 10-100 ms
            time.sleep(random.randint(10, 100) / 1000.0)
            
            print "task", item, "finished"

queue = Queue.Queue(0)

for i in range(WORKERS):
    Worker(queue).start() # start a worker

for i in range( JOB_COUNT ):
    queue.put(i)

for i in range(WORKERS):
    queue.put(None) # add end-of-queue markers

This came from http://effbot.org/librarybook/queue.htm