百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术资源 > 正文

Python 进程:掌控并发世界的钥匙

off999 2025-04-29 03:19 14 浏览 0 评论

Python 进程:掌控并发世界的钥匙

引言

进程,作为一种操作系统的基本调度单元,它不仅能够独立执行程序,还支持并发操作,这对于提升程序效率、改善用户体验至关重要。特别是在Python这样的解释型语言中,由于全局解释器锁(GIL)的存在,使得多线程在CPU密集型任务上的表现不如预期。此时,利用多进程便成为了一种有效的解决策略。

基础语法介绍

在Python中创建一个新进程非常直观。multiprocessing模块提供了所有必要的工具来轻松管理和控制进程。让我们从最基本的操作开始学习:

创建与启动进程

from multiprocessing import Process

def worker(name):
    print(f'Hello, I am {name}!')

if __name__ == '__main__':
    # 创建一个子进程
    p = Process(target=worker, args=('Worker 1',))
    # 启动进程
    p.start()
    # 等待子进程结束
    p.join()

上述代码展示了如何定义一个简单的函数worker并在一个新进程中执行它。通过Process类创建进程对象时,需要指定目标函数以及传递给该函数的参数。最后,使用start()方法启动进程,并通过join()等待其完成。

基础实例

接下来,我们通过一个更具体的例子来看看如何利用多个进程来加速数据处理流程:

假设我们需要对大量图片进行压缩处理。如果逐一进行,则耗时过长;而若能同时处理多张图片,效率将大大提高。

from multiprocessing import Pool
import os, time, random

def long_time_task(name):
    print('Run task %s (%s)...' % (name, os.getpid()))
    start = time.time()
    time.sleep(random.random() * 3)
    end = time.time()
    print('Task %s runs %0.2f seconds.' % (name, (end - start)))

if __name__ == '__main__':
    print('Parent process %s.' % os.getpid())
    p = Pool(4)  # 创建含有四个工作进程的进程池
    for i in range(5):
        p.apply_async(long_time_task, args=(i,))
    print('Waiting for all subprocesses done...')
    p.close()  # 关闭进程池,表示不能再往里面添加新的任务了
    p.join()   # 等待所有子进程结束
    print('All subprocesses done.')

这里我们使用了Pool类来创建一个包含四个工作进程的进程池。每个任务都将异步地分配给池中的空闲进程执行。当所有任务完成后,主程序继续往下执行。

进阶实例

在实际开发中,我们可能需要更复杂的进程间通信机制。例如,在分布式爬虫系统中,我们需要一个中心节点来分发任务给各个工作节点,并收集结果。这通常可以通过共享内存、队列等方式实现:

from multiprocessing import Manager, Process

def f(d, l):
    d[1] = '1'
    d['2'] = 2
    d[0.25] = None  # 注意字典键可以是任意类型
    l.reverse()

if __name__ == '__main__':
    manager = Manager()
    d = manager.dict()
    l = manager.list(range(10))

    p = Process(target=f, args=(d, l))
    p.start()
    p.join()

    print(d)
    print(l)

此例展示了如何利用Manager对象来创建可以在不同进程之间共享的数据结构。

实战案例

在真实的项目中,进程的应用往往更为复杂。比如在一个基于Python的分布式文件系统中,我们可能需要设计一种机制来支持文件的快速上传下载。这里不仅要考虑到单个请求的处理速度,还要兼顾系统的整体吞吐量。

具体实现时,我们可以设置专门的上传和下载进程,分别负责接收客户端请求和响应。同时,为了保证数据一致性,还需要引入额外的同步机制(如数据库事务),确保每个操作都被正确执行。

扩展讨论

虽然多进程在许多场景下都非常有用,但我们也应该注意到它并非万能药。首先,进程之间的通信开销相对较大,特别是在需要频繁交换数据的情况下。其次,由于每个进程都有独立的内存空间,因此无法直接访问其他进程中的变量,这增加了编程复杂性。

然而,正是这些挑战使得进程成为了一个值得深入研究的主题。掌握好进程管理技术,不仅能够显著提升程序性能,还能让你在面对复杂问题时更加游刃有余。

相关推荐

python入门到脱坑经典案例—清空列表

在Python中,清空列表是一个基础但重要的操作。clear()方法是最直接的方式,但还有其他方法也可以实现相同效果。以下是详细说明:1.使用clear()方法(Python3.3+推荐)...

python中元组,列表,字典,集合删除项目方式的归纳

九三,君子终日乾乾,夕惕若,厉无咎。在使用python过程中会经常遇到这四种集合数据类型,今天就对这四种集合数据类型中删除项目的操作做个总结性的归纳。列表(List)是一种有序和可更改的集合。允许重复...

Linux 下海量文件删除方法效率对比,最慢的竟然是 rm

Linux下海量文件删除方法效率对比,本次参赛选手一共6位,分别是:rm、find、findwithdelete、rsync、Python、Perl.首先建立50万个文件$testfor...

数据结构与算法——链式存储(链表)的插入及删除,

持续分享嵌入式技术,操作系统,算法,c语言/python等,欢迎小友关注支持上篇文章我们讲述了链表的基本概念及一些查找遍历的方法,本篇我们主要将一下链表的插入删除操作,以及采用堆栈方式如何创建链表。链...

Python自动化:openpyxl写入数据,插入删除行列等基础操作

importopenpyxlwb=openpyxl.load_workbook("example1.xlsx")sh=wb['Sheet1']写入数据#...

在Linux下软件的安装与卸载(linux里的程序的安装与卸载命令)

通过apt安装/协助软件apt是AdvancedPackagingTool,是Linux下的一款安装包管理工具可以在终端中方便的安装/卸载/更新软件包命令使用格式:安装软件:sudoapt...

Python 批量卸载关联包 pip-autoremove

pip工具在安装扩展包的时候会自动安装依赖的关联包,但是卸载时只删除单个包,无法卸载关联的包。pip-autoremove就是为了解决卸载关联包的问题。安装方法通过下面的命令安装:pipinsta...

用Python在Word文档中插入和删除文本框

在当今自动化办公需求日益增长的背景下,通过编程手段动态管理Word文档中的文本框元素已成为提升工作效率的关键技术路径。文本框作为文档排版中灵活的内容容器,既能承载多模态信息(如文字、图像),又可实现独...

Python 从列表中删除值的多种实用方法详解

#Python从列表中删除值的多种实用方法详解在Python编程中,列表(List)是一种常用的数据结构,具有动态可变的特性。当我们需要从列表中删除元素时,根据不同的场景(如按值删除、按索引删除、...

Python 中的前缀删除操作全指南(python删除前导0)

1.字符串前缀删除1.1使用内置方法Python提供了几种内置方法来处理字符串前缀的删除:#1.使用removeprefix()方法(Python3.9+)text="...

每天学点Python知识:如何删除空白

在Python中,删除空白可以分为几种不同的情况,常见的是针对字符串或列表中空白字符的处理。一、删除字符串中的空白1.删除字符串两端的空白(空格、\t、\n等)使用.strip()方法:s...

Linux系统自带Python2&yum的卸载及重装

写在前面事情的起因是我昨天在测试Linux安装Python3的shell脚本时,需要卸载Python3重新安装一遍。但是通过如下命令卸载python3时,少写了个3,不小心将系统自带的python2也...

如何使用Python将多个excel文件数据快速汇总?

在数据分析和处理的过程中,Excel文件是我们经常会遇到的数据格式之一。本文将通过一个具体的示例,展示如何使用Python和Pandas库来读取、合并和处理多个Excel文件的数据,并最终生成一个包含...

【第三弹】用Python实现Excel的vlookup功能

今天继续用pandas实现Excel的vlookup功能,假设我们的2个表长成这样:我们希望把Sheet2的部门匹在Sheet1的最后一列。话不多说,先上代码:importpandasaspd...

python中pandas读取excel单列及连续多列数据

案例:想获取test.xls中C列、H列以后(当H列后列数未知时)的所有数据。importpandasaspdfile_name=r'D:\test.xls'#表格绝对...

取消回复欢迎 发表评论: