Python如何实现队列？先进先出结构详解-Python教程-PHP中文网

Python如何实现队列？先进先出结构详解

絕刀狂花

发布： 2025-08-06 08:03:01

原创

311人浏览过

python实现队列的方法主要有两种：1.使用collections.deque，通过append添加元素，popleft移除元素；2.使用queue.queue，通过put入队，get出队。deque适用于单线程高效操作，queue.queue适用于多线程环境。队列常用于任务调度、消息传递、bfs、打印队列、缓存淘汰等场景。例如网络爬虫中通过队列控制并发请求。队列遵循fifo顺序，适用于按顺序处理任务；而栈遵循lifo顺序，适用于逆序处理，如函数调用、dfs等场景。选择合适的数据结构能提升程序效率。

Python如何实现队列？先进先出结构详解

Python实现队列，本质上就是利用一种数据结构来模拟现实生活中排队的行为，保证数据按照进入的顺序依次被处理。

解决方案

Python中实现队列，最常用的方法是使用

collections.deque

登录后复制

，它是一个双端队列，但在只进行尾部添加和头部移除操作时，就相当于一个标准的队列。当然，你也可以用

queue.Queue

登录后复制

，这是Python标准库中专门用于队列的模块，尤其适合多线程环境。

立即学习“Python免费学习笔记（深入）”；

使用

collections.deque

登录后复制

：

from collections import deque

queue = deque()

# 入队
queue.append(1)
queue.append(2)
queue.append(3)

# 出队
first = queue.popleft() # 1
second = queue.popleft() # 2

print(first, second)
print(queue) # deque([3])

登录后复制

deque

登录后复制

的优势在于它在两端进行插入和删除操作的时间复杂度都是O(1)，效率很高。

使用
```
queue.Queue
```
登录后复制
：

Tellers AI
Tellers是一款自动视频编辑工具，可以将文本、文章或故事转换为视频。

78

查看详情
```
import queue

q = queue.Queue()

# 入队
q.put(1)
q.put(2)
q.put(3)

# 出队
first = q.get() # 1
second = q.get() # 2

print(first, second)
print(q.qsize()) # 1
```
登录后复制
```
queue.Queue
```
登录后复制
是线程安全的，适合在多线程程序中使用，但单线程环境下
```
deque
```
登录后复制
通常更快。

队列的常见应用场景有哪些？

队列的应用非常广泛，例如：

任务调度： 操作系统会使用队列来管理待执行的任务，按照优先级或到达时间顺序执行。
消息传递： 在分布式系统中，消息队列用于异步地传递消息，解耦各个服务。
广度优先搜索（BFS）： 在图算法中，BFS使用队列来遍历节点。
打印队列： 打印机按照接收到的打印任务的顺序进行打印。
缓存淘汰： 某些缓存淘汰策略（如FIFO）会使用队列来记录数据的访问顺序。

如何用队列解决实际问题？

举个例子，假设你正在开发一个网络爬虫，需要爬取多个网页。为了避免一次性请求过多导致服务器崩溃，你可以使用队列来控制爬取的速度。

import requests
import time
from collections import deque
import threading

urls = [
    "http://example.com/page1",
    "http://example.com/page2",
    "http://example.com/page3",
    "http://example.com/page4",
    "http://example.com/page5",
]

queue = deque(urls)

def crawl(url):
    try:
        response = requests.get(url)
        print(f"Crawled {url}, status code: {response.status_code}")
        time.sleep(1) # 模拟爬取间隔
    except Exception as e:
        print(f"Failed to crawl {url}: {e}")

def worker():
    while queue:
        url = queue.popleft()
        crawl(url)

# 创建多个线程进行爬取
threads = []
for _ in range(3): # 3个线程
    t = threading.Thread(target=worker)
    threads.append(t)
    t.start()

for t in threads:
    t.join()

print("Finished crawling.")

登录后复制

这个例子展示了如何使用队列来控制并发爬取，避免对服务器造成过大压力。通过调整线程数量和爬取间隔，可以灵活地控制爬取速度。