Python thread and log

yuanqiao

import sys
import time
import datetime
import threading
import logging
from Queue import Queue
class Worker(threading.Thread):
def __init__(self, thread_name, queue, logger):
threading.Thread.__init__(self)
self.name = thread_name
self.queue = queue
self.logger = logger
self.is_stop = False
def stop(self):
self.is_stop = True
def run(self):
while not self.is_stop:
self.logger.info("thread[" + self.name + "] start process")
item = queue.get() # NOTE: If the queue is empty, this will be blocked!!!
if item is not None:
self.logger.info("thread[" + self.name + "] process: " + str(item))
else:
self.logger.info("thread[" + self.name + "] process: None")
self.logger.info("thread[" + self.name + "] end process")

logger = logging.getLogger()
logFileName = str(datetime.date.today()) + ".log"
fileHandler = logging.FileHandler(logFileName)
formatter = logging.Formatter("[%(asctime)s] [%(levelname)s] : %(message)s")
fileHandler.setFormatter(formatter)
logger.addHandler(fileHandler)
logger.setLevel(logging.INFO)
queue = Queue()
workers = []
for i in range(1, 20):
queue.put(i)
for j in range(1, 5):
worker = Worker("#" + str(j), queue, logger)
# worker.setDaemon(True)
worker.start()
workers.append(worker)

time.sleep(10)
# Stop the threads -- Start
for worker in workers:
worker.stop()
# NOTE: This will notify the waiting thread which blocked by "queue.get()" when the queue is empty
#       put None allow the thread to finish it's job before stop it!
queue.put(None)
for worker in workers:
worker.join()
# Stop the threads -- End