Queue

---

Queue是Python标准库中的线程安全的队列(FIFO)实现，提供了一个适用于多线程编程的先进先出的数据结构，即队列，用来在生产者和消费者之间的信息传递。

二种队列形式

---

FIFO队列

FIFO即First in First Out，先进先出。Queue提供了一个基本的FIFO容器，使用方法很简单。

参数：maxsize是一个整数，指明了队列中能存放的数据个数的上限。一旦达到上限，插入会导致堵塞，直到队列中的数据被消费掉。

案例

• 创建队列
  

1 2	from queue import Queue q = Queue(maxsize=3)

• 存取数据
  

1 2 3 4

# 存放数据 q.put('aaa') # 获取数据 q.get()

LIFO队列

LIFO即Last in First Out,后进先出。与栈的类似，使用也很简单,maxsize用法同上

• 创建队列
  

1 2	from queue import LifoQueue q = LifoQueue()

• 存放数据API语法同上
  

常用方法

• task_done()
  

告诉队列该任务已经处理完毕，队列的unfinished_tasks的属性-1

• join()
  

堵塞调用线程，直到队列中的所有任务被处理完毕，一旦有数据被加入队列，未完成的任务数就会增加。当消费者线程调用task_done()（意味着有消费者取得任务并完成任务），未完成的任务数就会减少。当未完成的任务数降到0（内部就是当队列的unfinished_tasks属性为0时），join()解除阻塞。

• put(item[, block[, timeout]])
  • 将item放入队列中。
    • 如果可选的参数block为True且timeout为空对象（默认的情况，阻塞调用，无超时）。
    • 如果timeout是个正整数，阻塞调用进程最多timeout秒，如果一直无空空间可用，抛出Full异常（带超时的阻塞调用）。
    • 如果block为False，如果有空闲空间可用将数据放入队列，否则立即抛出Full异常
      
    
    
• get()
  • 从队列中移除并返回一个数据。block跟timeout参数同put方法
    其非阻塞方法为｀get_nowait()｀相当与get(False)
    
    
• empty()
  • 如果队列为空，返回True，反之返回False
    
  
  

Queue

---

Queue是Python标准库中的线程安全的队列(FIFO)实现，提供了一个适用于多线程编程的先进先出的数据结构，即队列，用来在生产者和消费者之间的信息传递。

二种队列形式

---

FIFO队列

FIFO即First in First Out，先进先出。Queue提供了一个基本的FIFO容器，使用方法很简单。

参数：maxsize是一个整数，指明了队列中能存放的数据个数的上限。一旦达到上限，插入会导致堵塞，直到队列中的数据被消费掉。

案例

• 创建队列
  

1 2	from queue import Queue q = Queue(maxsize=3)

• 存取数据
  

1 2 3 4

# 存放数据 q.put('aaa') # 获取数据 q.get()

LIFO队列

LIFO即Last in First Out,后进先出。与栈的类似，使用也很简单,maxsize用法同上

• 创建队列
  

1 2	from queue import LifoQueue q = LifoQueue()

• 存放数据API语法同上
  

常用方法

• task_done()
  

告诉队列该任务已经处理完毕，队列的unfinished_tasks的属性-1

• join()
  

堵塞调用线程，直到队列中的所有任务被处理完毕，一旦有数据被加入队列，未完成的任务数就会增加。当消费者线程调用task_done()（意味着有消费者取得任务并完成任务），未完成的任务数就会减少。当未完成的任务数降到0（内部就是当队列的unfinished_tasks属性为0时），join()解除阻塞。

• put(item[, block[, timeout]])
  • 将item放入队列中。
    • 如果可选的参数block为True且timeout为空对象（默认的情况，阻塞调用，无超时）。
    • 如果timeout是个正整数，阻塞调用进程最多timeout秒，如果一直无空空间可用，抛出Full异常（带超时的阻塞调用）。
    • 如果block为False，如果有空闲空间可用将数据放入队列，否则立即抛出Full异常
      
    
    
• get()
  • 从队列中移除并返回一个数据。block跟timeout参数同put方法
    其非阻塞方法为｀get_nowait()｀相当与get(False)
    
    
• empty()
  • 如果队列为空，返回True，反之返回False