python队列基本使用

Python
queue队列

作用:

作用:

   解耦:使程序直接达成松耦合,修改多个函数,不会有串联关系。

   解耦:使程序直接促成松耦合,修改1个函数,不会有串联关系。

   升高处理效能:FIFO = 现进先出,LIFO = 后入先出。

   进步管理作用:FIFO = 现进先出,LIFO = 后入先出。

 

 

队列:

队列:

  队列可以出现的派八个线程,对排列的线程管理,并切每个要求管理线程只供给将呼吁的多寡放入队列容器的内存中,线程不供给拭目以俟,当排列达成管理完数据后,线程在按期来取多少就能够。请求数据的线程只与这么些行列容器存在关联,管理多少的线程down掉不会潜移默化到请求数据的线程,队列会派给其余线程管理那分多少,它达成了然耦,进步效用。队列内会有三个有各类的器皿,列表与这些容器是有分其余,列表中数据就算是排列的,但数量被取走后还会保留,而队列中那几个容器的数目被取后将不会保留。当必须在八个线程之间安全地交流消息时,队列在线程编制程序中尤其有用。

  队列能够现身的派八个线程,对排列的线程管理,并切各个须求管理线程只必要将呼吁的多少放入队列容器的内存中,线程没有必要静观其变,当排列实现管理完数据后,线程在有效期来取多少就能够。请求数据的线程只与这几个队列容器存在涉嫌,管理多少的线程down掉不会影响到请求数据的线程,队列会派给其余线程管理那分多少,它达成领会耦,提高效用。队列内会有3个有种种的容器,列表与那个容器是有分其他,列表中数据纵然是排列的,但数额被取走后还会保留,而队列中那些容器的数量被取后将不会保留。当必须在多少个线程之间安全地沟通音讯时,队列在线程编制程序中特地有用。

 

 

 

Python八种类型的队例:

参数介绍:

Queue:FIFO 即first in first out 先进先出

LifoQueue:LIFO 即last in first out 后进先出

PriorityQueue:优先队列,级别越低,越优先
deque:双边队列


导入三种队列,包

from queue import Queue,LifoQueue,PriorityQueue
# 先入先出 maxsize 可设置大小,设置block=False抛异常
class queue.Queue(maxsize=0)  

 # 后进先出 
class queue.LifoQueue(maxsize=0)

# 存储数据时可设置优先级的队列
# 优先级设置数越小等级越高
class queue.PriorityQueue(maxsize=0) 

# 放入数据
Queue.put(item, block=True, timeout=None)

# 取出数据 #没有数据将会等待
Queue.get(block=True, timeout=None)

# 如果1秒后没取到数据就退出
Queue.get(timeout = 1)


# 取数据,如果没数据抛queue.Empty异常
Queue.get_nowait()

# 查看队列大小
Queue.qsize()

# 返回True,如果空
Queue.empty() #return True if empty  

# 设置队列大小
Queue.full() 

# 后续调用告诉队列,任务的处理是完整的。
Queue.task_done()

 

 

Queue
先进先出队列:

生产者消费者模型:

#基本FIFO队列  先进先出 FIFO即First in First Out,先进先出
#maxsize设置队列中,数据上限,小于或等于0则不限制,容器中大于这个数则阻塞,直到队列中的数据被消掉
q = Queue(maxsize=0)

#写入队列数据
q.put(0)
q.put(1)
q.put(2)

#输出当前队列所有数据
print(q.queue)
#删除队列数据,并返回该数据
q.get()
#输也所有队列数据
print(q.queue)

# 输出:
# deque([0, 1, 2])
# deque([1, 2])
import threading,time
import queue

# 最多存入10个
q = queue.Queue(maxsize=10)

def producer(name):
    count = 1

    while True:

           # 生产一块骨头
            q.put("骨头 %s" % count )
            print("生产了骨头",count)
            count +=1
            time.sleep(0.3)

def consumer(name):
    while True:
        print("%s 取到[%s] 并且吃了它" %(name, q.get()))
        time.sleep(1)

       # 告知这个任务执行完了
        q.task_done() 

# 生成线程
p = threading.Thread(target=producer,args=("德国骨科",))
c = threading.Thread(target=consumer,args=("陈狗二",))
d = threading.Thread(target=consumer,args=("吕特黑",))

# 执行线程
p.start()
c.start()
d.start()

 

LifoOueue
后进先出队列:

发表评论

电子邮件地址不会被公开。 必填项已用*标注