python中的多进程Multiprocessing

---

title: python中的多进程Multiprocessing
date: 2022-04-17 15:05:39
tags: python python中的多进程Multiprocessing

当一个主程序都是顺序执行的时候，其中主程序有个别步骤需要IO或者cpu耗时较大，则主进程堵塞，影响整体效率，可以考虑多进程

Multiprocessing

python 内置了多进程模块Multiprocessing
Multiprocessing模块提供了一个Process类，下面演示其用法。

Usage

功能：当一个函数相对另一个函数是独立的，func不断往全局变量中写入数据，func1要不断取全局变量中的数据，可以采用多进程

import multiprocessing
import time

def func(mylist, i):
    print("进入func")
    while True:
        print('main'*5)
        i += 1
        mylist.append(i)  # 子进程改变List,主进程跟着改变
        time.sleep(1)

def func1(mylist):
    print("进入func1")
    while True:
        print("1"*10)
        time.sleep(2)
        print(mylist)

if __name__ == "__main__":
    mylist = multiprocessing.Manager().list()  # 主进程与子进程共享这个List
    p = multiprocessing.Process(target=func, args=(mylist, 0,))
    p1 = multiprocessing.Process(target=func1, args=(mylist,))
    p.start() #启动进程p
    p1.start() #启动进程p1
    p.join() #等待进程p终止
    p1.join() #等待进程p1终止

执行结果如下：

进入func
mainmainmainmainmain
进入func1
1111111111
mainmainmainmainmain
mainmainmainmainmain
[1, 2, 3]
1111111111
mainmainmainmainmain
mainmainmainmainmain
[1, 2, 3, 4, 5]
1111111111
mainmainmainmainmain
mainmainmainmainmain
[1, 2, 3, 4, 5, 6, 7]

p进程每秒1秒如数据到mylist中，p1进程每2秒获取一次mylist。

说明：此处进程间的通信是通过全局变量mylist来完成的。常见的进程通信也可以用Queue，Pipes来完成。此处没有涉及到进程锁。