threads1.py

#/bin/python
# Program for messing w/ threads

import threading
import Queue
import time

class WorkerThread(threading.Thread):

  def __init__(self, queue):
    threading.Thread.__init__(self)
    self.queue = queue
	
	
  def run(self):
    print "In WorkerThread"
    while True:
      counter = self.queue.get()
      print "Ordered to sleep for %d seconds!"%counter
      time.sleep(counter)
      print "Finished sleeping for %d seconds"%counter
      self.queue.task_done()
  
  

if __name__ == '__main__':
  queue = Queue.Queue()
  
  for i in range(10):
    print "Creating WorkerThread : %d"%i
    worker = WorkerThread(queue)
    worker.setDaemon(True)
    worker.start()
    print "WorkerThread %d Created!"%i

  for j in range(10):
    queue.put(j)
	
  queue.join()
  print "All tasks complete!"