python threading sample

python-threading-sample

import Queue
import threading
import multiprocessing

threads_count = 10 
q = Queue.Queue()

def sum():
    yet_not_finished = True
    while yet_not_finished:
        try: 
            item = q.get(False)                                    
            sum = int(item) + int(item)    
            print "%i" % sum
            q.task_done()
        except Queue.Empty:
            yet_not_finished = False


if __name__ == '__main__':

    for i in range(55):
        q.put(i)

    for i in range(threads_count):
         t = threading.Thread(target=sum)
         t.daemon = True
         t.start()

    q.join() #block until all tasks are done