Python中的多进程
off999 2025-04-29 03:19 27 浏览 0 评论
回顾
在Python进阶记录之基础篇(二十二)中,我们介绍了Python中对文本文件和二进制文件的简单操作,需要重点掌握文件的各种打开方式,以及简单的读写操作。今天我们讲一下Python中的多进程。
进程的基本概念
进程就是操作系统中执行的一个程序,操作系统以进程为单位分配存储空间,每个进程都有自己的地址空间、数据栈以及其他用于跟踪进程执行的辅助数据,操作系统管理所有进程的执行,为它们合理的分配资源。
进程可以通过fork或spawn的方式来创建新的进程来执行其他的任务,不过新的进程也有自己独立的内存空间,因此必须通过进程间通信机制来实现数据共享,具体的方式包括管道、信号、套接字、共享内存区等。
我们先来看这样一个例子:假设现在我们需要下载两个文件(具体怎么下载暂时先忽略)。按照我们之前掌握的知识点,就是一个一个地逐一下载。
上述代码中,我们将两个文件按顺序进行下载,为了模拟真实下载场景,我们设置相应的下载时间。可以看到,如果按顺序逐一下载,需要先等待一个文件下载完成后才能开始下一个文件的下载,整个过程下来需要耗费两个下载任务时间的总和,即9秒左右。
但是我们知道,这是两个毫不相关的下载任务,像这样逐一下载显然效率太低了。因此,就出现了并发编程的概念,而多进程就是Python实现并发编程的三种方式之一。
Python中多进程的创建方式
Python为我们提供了两种方式来实现多进程:系统的fork( )函数和multiprocessing
模块。其中multiprocessing模块是我们使用多进程的主要方式。
- 系统的fork( )函数
Unix和Linux操作系统提供了fork( )系统调用来创建进程,调用fork( )函数的是父进程,创建出的是子进程,子进程就是父进程的一个拷贝,但是子进程拥有自己的PID(进程标识)。
fork( )函数非常特殊,它会返回两次,父进程中可以通过fork( )函数的返回值得到子进程的PID,而子进程中的返回值永远都是0。
因此,在Unix和Linux操作系统中,Python的os模块也拥有fork( )函数。
fork( )函数可以创建子进程,通过子进程实现多进程。可以看到,通过创建子进程,耗时从原来的9秒左右缩短到5秒左右。
- multiprocessing模块
由于Windows系统中没有fork调用,因此我们在Windows系统中使用os.fork( )是无法运行的。
为了实现跨平台的多进程编程,Python为我们提供了multiprocessing模块。该模块中的Process类可以创建子进程,而且该模块还提供了更高级的封装,例如批量启动进程的进程池、用于进程间通信的队列和管道等。
因此,在Python的实际开发过程中,我们更多地是使用multiprocessing模块来实现多进程。
上述代码中,我们通过multiprocessing模块的Process类创建了进程对象,target参数表示目标函数,即进程启动后要执行的代码,args参数是目标函数所需要的参数,用一个元组接收。Process的start( )方法用于启动进程,而join( )方法表示等待进程执行结束再继续往下运行。
我们运行上述代码,可以发现两个下载任务一起执行,从而大大缩短了程序的执行时间。并且与fork( )函数相比,这种方式更加清晰。
进程池Pool
当下载文件增多,需要大量子进程时,我们也可以使用multiprocessing模块中的进程池Pool。假设现在有5个文件待下载,我们通过进程池Pool来实现并发下载。
上述代码中,我们创建了一个Pool对象,然后通过循环调用apply_async( )方法来创建进程。创建结束调用close( )方法,调用此方法后进程池就不能继续添加新的进程了。最后调用join( )方法等待所有子进程执行完毕。
从运行结果我们看到,程序并没有像我们预计地5个文件一起下载,而是先下载其中四个,直到四个中有一个下载完成才开始第5个。这是因为Pool线程池是有默认大小的,在我电脑上默认就是4,因此,最多同时执行4个进程。
如果你想同时执行5个,需要在创建Pool对象时传入一个5即可,p = Pool(5)。
进程间的通信
进程与进程之间有时也需要通信,在介绍进程的基本概念中我们提到,操作系统提供了很多机制来实现进程间的通信。Python的multiprocessing模块也包装了操作系统底层的机制,提供了对列(Queue)、管道(Pipes)等多种方式来实现数据共享。
下面我们以对列Queue为例,首先创建两个子进程,其中,一个往对列中写数据,一个从对列中读数据。
上述代码中,我们首先创建对列对象,然后创建两个进程分别用于数据的读和写。通过对列的put/get方法实现了两个进程之间的数据共享。
总结
以上内容介绍了进程的基本概念以及Python中多进程的使用方法,需要重点理解进程的概念。熟练掌握多进程的创建方法和各种基本操作。感谢大家的支持与关注,欢迎一起学习交流~
- 上一篇:一篇文章带你解析Python进程
- 下一篇:Python 进程:掌控并发世界的钥匙
相关推荐
- 阿里云国际站ECS:阿里云ECS如何提高网站的访问速度?
-
TG:@yunlaoda360引言:速度即体验,速度即业务在当今数字化的世界中,网站的访问速度已成为决定用户体验、用户留存乃至业务转化率的关键因素。页面加载每延迟一秒,都可能导致用户流失和收入损失。对...
- 高流量大并发Linux TCP性能调优_linux 高并发网络编程
-
其实主要是手里面的跑openvpn服务器。因为并没有明文禁p2p(哎……想想那么多流量好像不跑点p2p也跑不完),所以造成有的时候如果有比较多人跑BT的话,会造成VPN速度急剧下降。本文所面对的情况为...
- 性能测试100集(12)性能指标资源使用率
-
在性能测试中,资源使用率是评估系统硬件效率的关键指标,主要包括以下四类:#性能测试##性能压测策略##软件测试#1.CPU使用率定义:CPU处理任务的时间占比,计算公式为1-空闲时间/总...
- Linux 服务器常见的性能调优_linux高性能服务端编程
-
一、Linux服务器性能调优第一步——先搞懂“看什么”很多人刚接触Linux性能调优时,总想着直接改配置,其实第一步该是“看清楚问题”。就像医生看病要先听诊,调优前得先知道服务器“哪里...
- Nginx性能优化实战:手把手教你提升10倍性能!
-
关注△mikechen△,十余年BAT架构经验倾囊相授!Nginx是大型架构而核心,下面我重点详解Nginx性能@mikechen文章来源:mikechen.cc1.worker_processe...
- 高并发场景下,Spring Cloud Gateway如何抗住百万QPS?
-
关注△mikechen△,十余年BAT架构经验倾囊相授!大家好,我是mikechen。高并发场景下网关作为流量的入口非常重要,下面我重点详解SpringCloudGateway如何抗住百万性能@m...
- Kubernetes 高并发处理实战(可落地案例 + 源码)
-
目标场景:对外提供HTTPAPI的微服务在短时间内收到大量请求(例如每秒数千至数万RPS),要求系统可弹性扩容、限流降级、缓存减压、稳定运行并能自动恢复。总体思路(多层防护):边缘层:云LB...
- 高并发场景下,Nginx如何扛住千万级请求?
-
Nginx是大型架构的必备中间件,下面我重点详解Nginx如何实现高并发@mikechen文章来源:mikechen.cc事件驱动模型Nginx采用事件驱动模型,这是Nginx高并发性能的基石。传统...
- Spring Boot+Vue全栈开发实战,中文版高清PDF资源
-
SpringBoot+Vue全栈开发实战,中文高清PDF资源,需要的可以私我:)SpringBoot致力于简化开发配置并为企业级开发提供一系列非业务性功能,而Vue则采用数据驱动视图的方式将程序...
- Docker-基础操作_docker基础实战教程二
-
一、镜像1、从仓库获取镜像搜索镜像:dockersearchimage_name搜索结果过滤:是否官方:dockersearch--filter="is-offical=true...
- 你有空吗?跟我一起搭个服务器好不好?
-
来人人都是产品经理【起点学院】,BAT实战派产品总监手把手系统带你学产品、学运营。昨天闲的没事的时候,随手翻了翻写过的文章,发现一个很严重的问题。就是大多数时间我都在滔滔不绝的讲理论,却很少有涉及动手...
- 部署你自己的 SaaS_saas如何部署
-
部署你自己的VPNOpenVPN——功能齐全的开源VPN解决方案。(DigitalOcean教程)dockovpn.io—无状态OpenVPNdockerized服务器,不需要持久存储。...
- Docker Compose_dockercompose安装
-
DockerCompose概述DockerCompose是一个用来定义和管理多容器应用的工具,通过一个docker-compose.yml文件,用YAML格式描述服务、网络、卷等内容,...
- 京东T7架构师推出的电子版SpringBoot,从构建小系统到架构大系统
-
前言:Java的各种开发框架发展了很多年,影响了一代又一代的程序员,现在无论是程序员,还是架构师,使用这些开发框架都面临着两方面的挑战。一方面是要快速开发出系统,这就要求使用的开发框架尽量简单,无论...
- Kubernetes (k8s) 入门学习指南_k8s kubeproxy
-
Kubernetes(k8s)入门学习指南一、什么是Kubernetes?为什么需要它?Kubernetes(k8s)是一个开源的容器编排系统,用于自动化部署、扩展和管理容器化应用程序。它...
欢迎 你 发表评论:
- 一周热门
-
-
抖音上好看的小姐姐,Python给你都下载了
-
全网最简单易懂!495页Python漫画教程,高清PDF版免费下载
-
Python 3.14 的 UUIDv6/v7/v8 上新,别再用 uuid4 () 啦!
-
python入门到脱坑 输入与输出—str()函数
-
宝塔面板如何添加免费waf防火墙?(宝塔面板开启https)
-
Python三目运算基础与进阶_python三目运算符判断三个变量
-
(新版)Python 分布式爬虫与 JS 逆向进阶实战吾爱分享
-
慕ke 前端工程师2024「完整」
-
失业程序员复习python笔记——条件与循环
-
飞牛NAS部署TVGate Docker项目,实现内网一键转发、代理、jx
-
- 最近发表
- 标签列表
-
- python计时 (73)
- python安装路径 (56)
- python类型转换 (93)
- python进度条 (67)
- python吧 (67)
- python的for循环 (65)
- python格式化字符串 (61)
- python静态方法 (57)
- python列表切片 (59)
- python面向对象编程 (60)
- python 代码加密 (65)
- python串口编程 (77)
- python封装 (57)
- python写入txt (66)
- python读取文件夹下所有文件 (59)
- python操作mysql数据库 (66)
- python获取列表的长度 (64)
- python接口 (63)
- python调用函数 (57)
- python多态 (60)
- python匿名函数 (59)
- python打印九九乘法表 (65)
- python赋值 (62)
- python异常 (69)
- python元祖 (57)
