pythread.py

# coding: utf-8

import os
import sys
import Queue
import threading
import logging
import time


num_workers = 3


logging.basicConfig(level=logging.DEBUG, format="%(asctime)s %(threadName)s %(message)s")

q = Queue.Queue()

def worker():
    try:
        while True:
            item = q.get()
            logging.info("get item: %d", item)
            q.task_done()
    except Exception:
        logging.error("caught exception", exc_info=True)

for i in range(num_workers):
    t = threading.Thread(target=worker, name="t{0:d}".format(i))
    t.daemon = True
    t.start()

for item in [1, 4, 3, 5, 2, 7, 8, 6, 9]:
    time.sleep(item)
    q.put(item)

q.join()