import threading 
from queue import Queue

#工作线程
class WorkerThread(threading.Thread): 
  def __init__(self,*args,**kwargs): 
    threading.Thread.__init__(self,*args,**kwargs) 
    self.input_queue = Queue()          #消息队列
  def send(self,item):                  #发送消息
    self.input_queue.put(item) 
  def close(self):                      #结束线程
    self.input_queue.put(None) 
    self.input_queue.join() 
  def run(self):                        #线程函数
    while True: 
      item = self.input_queue.get() 
      if item is None:                  #哨兵
          break 
      # 处理项（使用有用的工作代替） 
      print(item) 
      self.input_queue.task_done()      #项已处理完成
    # 完成。指示收到和返回了哨兵 
    self.input_queue.task_done() 
    return 
 
# 使用示例 
w = WorkerThread() 
w.start() 
w.send("hello")    # 将项发送给工作线程（通过队列） 
w.send("world") 
w.close()