import threadingfrom 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()
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。