首页 > 代码库 > PYTHON线程知识再研习F---队列同步Queue
PYTHON线程知识再研习F---队列同步Queue
让我们考虑更复杂的一种场景：产品是各不相同的。这时只记录一个数量就不够了，还需要记录每个产品的细节。很容易想到需要用一个容器将这些产品记录下来。
Python的Queue模块中提供了同步的、线程安全的队列类，包括FIFO（先入先出)队列Queue，LIFO（后入先出）队列 LifoQueue，和优先级队列PriorityQueue。这些队列都实现了锁原语，能够在多线程中直接使用。可以使用队列来实现线程间的同步。
#!/usr/bin/env python# -*- coding: utf-8 -*-import threadingimport timefrom Queue import Queueclass Producer(threading.Thread): def run(self): global queue count = 0 while True: for i in range(100): if queue.qsize() > 1000: pass else: count += 1 msg = ‘生成产品‘ + str(count) queue.put(count) print msg time.sleep(1)class Consumer(threading.Thread): def run(self): global queue while True: for i in range(3): if queue.qsize() < 100: pass else: msg = self.name + ‘消费了‘ + queue.get() print msg time.sleep(1)queue = Queue()def test(): for i in range(500): queue.put(‘初始产品‘ + str(i)) for i in range(2): p = Producer() p.start() for i in range(5): c = Consumer() c.start()if __name__ == ‘__main__‘: test()
PYTHON线程知识再研习F---队列同步Queue
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。