python threading queue
浏览数：35 /
时间：2015年06月08日
import queue,threading l=threading.Lock() class MyThread(threading.Thread): def __init__(self): threading.Thread.__init__(self) global que self.queue = que def run(self): while True: if self.queue.empty(): break item = self.queue.get() if l.acquire(1): print( self.name,item) l.release() self.queue.task_done() return que = queue.Queue() for x in range(200): que.put(x) for x in range(3): t=MyThread() t.start() que.join()
郑重声明：本站内容如果来自互联网及其他传播媒体，其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享，并不代表本站赞同其观点和对其真实性负责，也不构成任何其他建议。
