Python3多进程multiprocessing模块实例详解_sharedctypes - CSDN文库

multiprocessing

160 浏览量更新于2023-05-10 评论 1 收藏 72KB PDF 举报

身份认证购VIP最低享 7 折!

领优惠券(最高得80元）

资源详情

资源评论

资源推荐

Python3多进程多进程 multiprocessing 模块实例详解模块实例详解

主要介绍了Python3多进程 multiprocessing 模块,结合实例形式详细分析了Python3多进程 multiprocessing 模块

的概念、原理、相关方法使用技巧与注意事项,需要的朋友可以参考下

本文实例讲述了Python3多进程 multiprocessing 模块。分享给大家供大家参考，具体如下：

多进程多进程 Multiprocessing 模块模块

multiprocessing 模块官方说明文档

Process 类类

Process 类用来描述一个进程对象。创建子进程的时候，只需要传入一个执行函数和函数的参数即可完成 Process 示例的创

建。

star() 方法启动进程，

join() 方法实现进程间的同步，等待所有进程退出。

close() 用来阻止多余的进程涌入进程池 Pool 造成进程阻塞。

multiprocessing.Process(group=None, target=None, name=None, args=(), kwargs={}, *, daemon=None)

target 是函数名字，需要调用的函数

args 函数需要的参数，以 tuple 的形式传入

示例：示例：

import multiprocessing

import os

def run_proc(name):

print('Child process {0} {1} Running '.format(name, os.getpid()))

if __name__ == '__main__':

print('Parent process {0} is Running'.format(os.getpid()))

for i in range(5):

p = multiprocessing.Process(target=run_proc, args=(str(i),))

print('process start')

p.start()

p.join()

print('Process close')

结果：

Parent process 809 is Running

process start

process start

process start

process start

process start

Child process 0 810 Running

Child process 1 811 Running

Child process 2 812 Running

Child process 3 813 Running

Child process 4 814 Running

Process close

Pool

Pool 可以提供指定数量的进程供用户使用，默认是 CPU 核数。当有新的请求提交到 Poll 的时候，如果池子没有满，会创建

一个进程来执行，否则就会让该请求等待。

- Pool 对象调用 join 方法会等待所有的子进程执行完毕

- 调用 join 方法之前，必须调用 close

- 调用 close 之后就不能继续添加新的 Process 了

pool.apply_async

apply_async 方法用来同步执行进程，允许多个进程同时进入池子。

import multiprocessing

import os

import time

def run_task(name):

本内容试读结束，登录后可阅读更多

下载后可阅读完整内容，剩余3页未读，立即下载

评论0

weixin_38691319

粉丝: 2
资源: 910

会员权益专享

图片转文字

全年可省5，000元立即开通

最新资源

资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！点击此处反馈