人生苦短之我用Python篇（队列、生产者和消费者模型）

队列：

queue. Queue ( maxsize=0 ) #先入先出 queue. LifoQueue ( maxsize=0 ) #last in fisrt out  queue. PriorityQueue ( maxsize=0 ) #存储数据时可设置优先级的队列 Queue. qsize () Queue. put ( item ,  block=True ,  timeout=None ) Queue. put_nowait ( item ) Queue. get ( block=True ,  timeout=None ) Queue. get_nowait () Queue. empty () #return True if empty   Queue. full () # return True if full

import queue

q = queue.PriorityQueue()

q.put((-1,"chenronghua"))
q.put((3,"hanyang"))
q.put((10,"alex"))
q.put((6,"wangsen"))print(q.get())print(q.get())print(q.get())print(q.get())


q  = queue.LifoQueue()

q.put(1)
q.put(2)
q.put(3)print(q.get())print(q.get())print(q.get())

 

生产者和消费者模型：

在并发编程中使用生产者和消费者模式能够解决绝大多数并发问题。该模式通过平衡生产线程和消费线程的工作能力来提高程序的整体处理数据的速度。

为什么要使用生产者和消费者模式

在线程世界里，生产者就是生产数据的线程，消费者就是消费数据的线程。在多线程开发当中，如果生产者处理速度很快，而消费者处理速度很慢，那么生产者就必须等待消费者处理完，才能继续生产数据。同样的道理，如果消费者的处理能力大于生产者，那么消费者就必须等待生产者。为了解决这个问题于是引入了生产者和消费者模式。

什么是生产者消费者模式

生产者消费者模式是通过一个容器来解决生产者和消费者的强耦合问题。生产者和消费者彼此之间不直接通讯，而通过阻塞队列来进行通讯，所以生产者生产完数据之后不用等待消费者处理，直接扔给阻塞队列，消费者不找生产者要数据，而是直接从阻塞队列里取，阻塞队列就相当于一个缓冲区，平衡了生产者和消费者的处理能力。

__author__ = "Alex Li"import threading,timeimport queue

q = queue.Queue(maxsize=2)def Producer(name):
    count = 1while True:
        q.put("骨头%s" % count)print("生产了骨头",count)
        count +=1time.sleep(0.3)def  Consumer(name):#while q.qsize()>0:while True:print("[%s] 取到[%s] 并且吃了它..." %(name, q.get()))
        time.sleep(0.5)



p = threading.Thread(target=Producer,args=("主人",))
c = threading.Thread(target=Consumer,args=("Dog1",))
c1 = threading.Thread(target=Consumer,args=("Dog2",))
p.start()
c.start()
c1.start()

 

查看更多关于人生苦短之我用Python篇（队列、生产者和消费者模型）的详细内容...