怎么在Python爬虫中使用ThreadPoolExecutor控制并发数?

胖枫姑娘_7199

胖枫姑娘_7199

2026-11-02

596人浏览

原创

max_workers控制线程池中同时存活的最大线程数,而非瞬时执行任务数;设为5时,100个请求最多5线程并发,其余排队,其默认值通常为min(32, os.cpu_count() + 4)。

怎么在python爬虫中使用threadpoolexecutor控制并发数?

ThreadPoolExecutor 的 max_workers 参数到底控制什么

它控制的是线程池中**同时存活的最大线程数**,不是“同一时刻正在执行的任务数”——因为线程可能阻塞在 I/O(比如 requests.get()),但依然算作“存活”。所以设 max_workers=5,爬虫发 100 个请求时,最多有 5 个线程在跑,其余任务排队等待空闲线程。

常见误解是以为它能限制 TCP 连接数或 HTTP 并发请求数,其实不能。真正影响网络并发的还有:requests.Session 的连接池、DNS 缓存、系统文件描述符限制。

  • 若不指定 max_workers,默认值通常是 min(32, os.cpu_count() + 4),对 I/O 密集型爬虫明显偏高,容易触发反爬或连接拒绝
  • 实际建议从 3–10 开始试,配合目标网站响应时间与稳定性调整
  • 设得过小(如 1)会退化成串行,失去并发意义;过大(如 50)可能被封 IP 或遭遇 ConnectionError: Max retries exceeded

requests + ThreadPoolExecutor 组合时必须加 session 复用

每次新建 requests.get() 都会创建新连接,即使用了线程池,也极易耗尽本地端口或触发服务器限流。正确做法是在每个线程里复用一个 Session 实例,或更稳妥地——在 ThreadPoolExecutor 外创建单个 Session,并传入任务函数。

from concurrent.futures import ThreadPoolExecutor
import requests
<p>session = requests.Session()</p><h1>复用连接池,避免重复握手</h1><p>session.headers.update({'User-Agent': 'Mozilla/5.0'})</p><div class="aritcle_card flexRow artxards">
											<div class="artcardd flexRow">
												<a class="aritcle_card_img" rel="nofollow" href="/xiazai/skill11111" title="python-flask-vue-creator"><img
														src="https://img.php.cn/upload/skill/001/246/273/6adaf20e695c2374.jpg" alt="python-flask-vue-creator" onerror="this.onerror='';this.src='/static/lhimages/moren/morentu.png'" ></a>
												<div class="aritcle_card_info flexColumn">
													<a rel="nofollow" href="/xiazai/skill11111" title="python-flask-vue-creator" class="overflowclass">python-flask-vue-creator</a>
													<p class="overflowclass">创建 Flask + Vue.js 全栈项目,采用单端口架构、uv 依赖管理、结构化日志和生产级前端设计。当用户要求以下操作时触发:创建新的 Flask+Vue 项目、搭建 Web 应用、构建全栈 Python+Vue 应用、初始化 Flask Web 项目、设置单端口 Flask 前后端项目。触发词:新建项目、创建项目、搭建项目、Flask项目、Vue项目。</p>
												</div>
												<a rel="nofollow" href="/xiazai/skill11111" title="python-flask-vue-creator" class="aritcle_card_btn flexRow flexcenter"><b></b><span>下载</span>
												</a>
											</div>
										</div><p>def fetch_url(url):
try:
resp = session.get(url, timeout=10)
return resp.status_code, len(resp.content)
except Exception as e:
return None, str(e)</p><p>urls = ['<a href="https://www.php.cn/link/5f69e19efaba426d62faeab93c308f5c">https://www.php.cn/link/5f69e19efaba426d62faeab93c308f5c</a>'] * 20
with ThreadPoolExecutor(max_workers=5) as executor:
results = list(executor.map(fetch_url, urls))
</p>
  • 不要在 fetch_url 内部新建 Session,否则连接池失效,max_workers 就只是“并发开浏览器”的假象
  • 如果需要不同 UA 或 cookie,可考虑用 threading.local() 绑定每线程一个 session,但多数场景共享 session + 合理 headers 更稳
  • 记得调用 session.close()(本例中由上下文管理器自动处理)

遇到 “OSError: [Errno 24] Too many open files” 怎么办

这是典型的系统级资源超限,不是 Python 报错,而是 Linux/macOS 对单进程打开文件数(包括 socket)做了默认限制(通常 1024)。ThreadPoolExecutor 开太多线程 + 每个线程发多个请求,很容易撞上这个墙。

  • 先查当前限制:ulimit -n;临时提高:ulimit -n 4096(仅当前 shell 有效)
  • 更治本的是降低 max_workers,同时在 Session 上显式限制连接池大小:session.adapters['https://'].pool_connections = 10、pool_maxsize = 10
  • 如果用 urllib3 底层,注意 PoolManager 的 maxsize 和 num_pools 也要匹配线程数,否则连接复用率低,照样打满 fd

为什么有时并发数设对了,但实际请求数还是远超预期

因为 ThreadPoolExecutor.submit() 或 .map() 是**立即提交所有任务到队列**,哪怕线程池只有 3 个 worker,你 submit 1000 个 URL,这 1000 个任务对象就立刻生成并持有各自的参数(包括 URL 字符串、闭包变量等),内存占用陡增,且一旦某个任务抛出未捕获异常,可能中断整个批次。

  • 用 executor.map() 时,输入迭代器会被提前展开(除非是生成器且 executor 内部做惰性处理,但标准库不保证),慎用于超大 URL 列表
  • 更可控的方式是分批提交:每次取 min(100, len(urls)) 个 URL,list(executor.map(...)) 完再取下一批
  • 务必包住任务函数的 try/except,否则一个失败会导致后续结果顺序错乱或丢失,比如用 executor.submit() 后调用 future.result() 时再捕获

线程池本身不解决 DNS 解析慢、SSL 握手卡顿、目标服务随机 503 这些问题,max_workers 只是第一道水闸,后面还得靠重试策略、请求间隔、User-Agent 轮换来兜底。

Python免费学习笔记(深入):立即使用
在学习笔记中,你将探索 Python 的核心概念和高级技巧!

相关文章

PHP速学视频免费教程(入门到精通)
PHP速学视频免费教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

python 爬虫 python包

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
python打包成可执行文件
python打包成可执行文件

本专题为大家带来python打包成可执行文件相关的文章,大家可以免费的下载体验。

2023.07.20

1851

4

python能做什么
python能做什么

python能做的有:可用于开发基于控制台的应用程序、多媒体部分开发、用于开发基于Web的应用程序、使用python处理数据、系统编程等等。本专题为大家提供python相关的各种文章、以及下载和课程。

2023.07.25

5024

7

format在python中的用法
format在python中的用法

Python中的format是一种字符串格式化方法,用于将变量或值插入到字符串中的占位符位置。通过format方法,我们可以动态地构建字符串,使其包含不同值。php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

2023.07.31

1809

3

python教程
python教程

Python已成为一门网红语言,即使是在非编程开发者当中,也掀起了一股学习的热潮。本专题为大家带来python教程的相关文章,大家可以免费体验学习。

2023.08.03

30137

23

python环境变量的配置
python环境变量的配置

Python是一种流行的编程语言,被广泛用于软件开发、数据分析和科学计算等领域。在安装Python之后,我们需要配置环境变量,以便在任何位置都能够访问Python的可执行文件。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

2023.08.04

3587

5

python eval
python eval

eval函数是Python中一个非常强大的函数,它可以将字符串作为Python代码进行执行,实现动态编程的效果。然而,由于其潜在的安全风险和性能问题,需要谨慎使用。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

2023.08.04

3607

5

scratch和python区别
scratch和python区别

scratch和python的区别:1、scratch是一种专为初学者设计的图形化编程语言,python是一种文本编程语言;2、scratch使用的是基于积木的编程语法,python采用更加传统的文本编程语法等等。本专题为大家提供scratch和python相关的文章、下载、课程内容,供大家免费下载体验。

2023.08.11

1243

5

python合并两个列表
python合并两个列表

Python是一种强大的编程语言,具有许多方便的功能和工具。在Python中,有多种方法可以合并两个列表。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

2023.08.10

616

4

python是前端还是后端
python是前端还是后端

Python属于前端也属于后端,其灵活性和丰富的生态系统使得开发人员能够在不同的领域中灵活运用。本专题为大家提供python相关的文章、下载、课程内容,供大家免费下载体验。

2023.08.11

2803

5

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程