全网整合营销服务商

电脑端+手机端+微信端=数据同步管理

免费咨询热线:400-708-3566

Python如何构建多线程任务_并发处理基础知识【教程】

Python多线程适合IO密集型任务,因CPython的GIL限制其不适用于CPU密集型计算;需用join()等待线程完成、Lock保证共享数据安全、ThreadPoolExecutor简化线程池管理,并注意避免死锁与资源泄漏。

Python构建多线程任务,核心是用 threading 模块启动多个线程并发执行函数,但要注意:CPython有GIL(全局解释器锁),所以多线程**适合IO密集型任务**(如网络请求、文件读写),不适合CPU密集型计算(此时应选 multiprocessing)。

一、基础写法:创建并启动线程

最直接的方式是把目标函数传给 Thread 对象,调用 start() 启动:

  • 每个线程独立运行,主线程不会自动等待子线程结束
  • 需要用 join() 显式等待线程完成,否则可能主线程退出、子线程被强制终止

示例:

import threading
import time

def task(name):
  print(f"线程 {name} 开始")
  time.sleep(2)
  print(f"线程 {name} 结束")

t1 = threading.Thread(target=task, args=("A",))
t2 = threading.Thread(target=task, args=("B",))
t1.start()
t2.start()
t1.join() # 等待t1完成
t2.join() # 等待t2完成
print("全部完成")

二、共享数据与线程安全

多个线程访问同一变量(如全局计数器、列表)时,可能因执行时序交错导致结果错误——这就是**竞态条件**。

  • threading.Lock 加锁是最常用解决方式
  • lock.acquire() 和 lock.release() 要配对;推荐用 with 语句自动管理

示例(安全计数):

counter = 0
lock = threading.Lock()

def increment():
  global counter
  for _ in range(100000):
    with lock:
      counter += 1

t1 = threading.Thread(target=increment)
t2 = threading.Thread(target=increment)
t1.start(); t2.start()
t1.join(); t2.join()
print(counter) # 输出 200000(无锁时可能小于该值)

三、用 ThreadPoolExecutor 管理线程池

比起手动创建/管理线程,concurrent.futures.ThreadPoolExecutor 更简洁、健壮,支持异步提交和结果获取:

  • submit() 提交单个任务,返回 Future 对象
  • map() 批量提交同函数、不同参数的任务,按输入顺序返回结果
  • with 语句可自动关闭线程池,避免资源泄漏

示例(并发请求多个网页):

from concurrent.futures import ThreadPoolExecutor
import requests

urls = ["https://httpbin.org/delay/1"] * 5

def fetch(url):
  return requests.get(url).status_code

with ThreadPoolExecutor(max_workers=3) as executor:
  results = list(executor.map(fetch, urls))
print(results) # [200, 200, 200, 200, 200]

四、常见陷阱提醒

  • 不要在线程中修改未加锁的共享变量(尤其字典、列表 append/pop)
  • 避免死锁:多个锁嵌套时注意加锁顺序一致;尽量用单个锁或 with 语句
  • 主线程退出 = 整个程序退出,守护线程(daemon=True)会随主线程结束而被杀,非守护线程必须 join 完成
  • 调试多线程难:加日志、用 time.sleep() 暴露竞态问题,再针对性加锁

基本上就这些。多线程不是“开越多越快”,合理控制线程数(通常略大于CPU核心数或根据IO等待时间调整),比盲目堆数量更有效。


# python  # app  # 并发请求  # 无锁 


相关文章: 如何用手机制作网站和网页,手机移动端的网站能制作成中英双语的吗?  如何通过网站建站时间优化SEO与用户体验?  建站之星IIS配置教程:代码生成技巧与站点搭建指南  专业网站制作服务公司,有哪些网站可以免费发布招聘信息?  广东专业制作网站有哪些,广东省能源集团有限公司官网?  内部网站制作流程,如何建立公司内部网站?  成都品牌网站制作公司,成都营业执照年报网上怎么办理?  郑州企业网站制作公司,郑州招聘网站有哪些?  建站之星在线版空间:自助建站+智能模板一键生成方案  官网建站费用明细查询_企业建站套餐价格及收费标准指南  如何批量查询域名的建站时间记录?  宁波免费建站如何选择可靠模板与平台?  建站之星各版本价格是多少?  建站主机与服务器功能差异如何区分?  济南网站建设制作公司,室内设计网站一般都有哪些功能?  网站制作软件有哪些,制图软件有哪些?  网站制作公司,橙子建站是合法的吗?  北京制作网站的公司排名,北京三快科技有限公司是做什么?北京三快科技?  网站制作新手教程,新手建设一个网站需要注意些什么?  胶州企业网站制作公司,青岛石头网络科技有限公司怎么样?  宝塔Windows建站如何避免显示默认IIS页面?  定制建站流程解析:需求评估与SEO优化功能开发指南  如何使用Golang table-driven基准测试_多组数据测量函数效率  盐城做公司网站,江苏电子版退休证办理流程?  GML (Geography Markup Language)是什么,它如何用XML来表示地理空间信息?  如何通过虚拟主机快速搭建个人网站?  建站主机是什么?如何选择适合的建站主机?  如何用IIS7快速搭建并优化网站站点?  南宁网站建设制作定制,南宁网站建设可以定制吗?  移动端手机网站制作软件,掌上时代,移动端网站的谷歌SEO该如何做?  如何在VPS电脑上快速搭建网站?  免费的流程图制作网站有哪些,2025年教师初级职称申报网上流程?  建站之星如何助力企业快速打造五合一网站?  如何通过VPS建站无需域名直接访问?  建站上传速度慢?如何优化加速网站加载效率?  如何在阿里云通过域名搭建网站?  如何快速配置高效服务器建站软件?  企业宣传片制作网站有哪些,传媒公司怎么找企业宣传片项目?  手机网站制作平台,手机靓号代理商怎么制作属于自己的手机靓号网站?  大连 网站制作,大连天途有线官网?  如何快速查询网站的真实建站时间?  c# 服务器GC和工作站GC的区别和设置  模具网站制作流程,如何找模具客户?  ,怎么用自己头像做动态表情包?  c# 在高并发下使用反射发射(Reflection.Emit)的性能  如何用AWS免费套餐快速搭建高效网站?  如何用VPS主机快速搭建个人网站?  如何制作一个表白网站视频,关于勇敢表白的小标题?  如何在Golang中处理模块冲突_解决依赖版本不兼容问题  如何高效配置香港服务器实现快速建站? 

您的项目需求

*请认真填写需求信息,我们会在24小时内与您取得联系。