python_并发编程—

from multiprocessing import Process

import os

def func1():

    print('子进程1',os.getpid())   #子进程：获取当前进程的进程号

    print('子进程的父进程:', os.getppid()) #获取进程的父进程id

def func2():

    print('子进程2',os.getpid())

    print('子进程的父进程:', os.getppid())

def func3():

    print('子进程3',os.getpid())

    print('子进程的父进程:', os.getppid())

if __name__ == '__main__':

    p1 = Process(target=func1)  #注册：将函数名（内存地址）注册进子进程

    p2 = Process(target=func2)  #p1是一个进程对象

    p3 = Process(target=func3)

    p1.start()  #开启了一个子进程

    p2.start()  #三个并行的子进程

    p3.start()

    print('父进程:',os.getpid())  #父进程：获取当前进程的进程号

    print('父进程的父进程:', os.getppid()) #获取进程的父进程id

　　子进程的执行顺序会变化，说明三个子进程是并行的。

　　传递参数：

from multiprocessing import Process

import os

def func1(args):    #args接收参数

    print('子进程1',os.getpid())   #子进程：获取当前进程的进程号

    print('子进程的父进程:', os.getppid()) #获取进程的父进程id

    print(args)     #打印传递进来的参数

if __name__ == '__main__':

    p1 = Process(target=func1,args=('参数',))   #以元组的形式传递参数，如果只传递一个参数必须要加一个逗号

    p1.start()

    print('父进程:',os.getpid())  #父进程：获取当前进程的进程号

    print('父进程的父进程:', os.getppid()) #获取进程的父进程id

结果：

　　开启多个子进程方法：

from multiprocessing import Process

def func1(args):

    print('*'*args)

if __name__ == '__main__':

    # 可以使用for循环实现开启多个子进程

    for i in range(1,5):

        p1 = Process(target=func1,args=(i,))

        p1.start()

结果1：　　结果2：

　　多进程join()方法：

from multiprocessing import Process

def func1(args):

    print('子进程1')

    print(args)

if __name__ == '__main__':

    p1 = Process(target=func1,args=('参数',))

    p1.start()

    print('hahahahha')

    # 感知一个子进程的结束，将异步变为同步：join之前为异步

    p1.join()

    # join之后为同步

    print('qqqqqqqqq')

结果：

实践：我们想实现先异步输出10句话，最后同步输出执行完毕的结果。

from multiprocessing import Process

def func1(args):

    print('*'*args)

if __name__ == '__main__':

    for i in range(10):

        p1 = Process(target=func1,args=(i,))

        p1.start()

    p1.join()

    print('执行完毕！')

但是我们发现，“执行完毕”四个字总是跟随在最长的一句话后面打印输出，然而因为上面10句话是异步的，最长的那句话并不是每次都最后输出，所以我们这样不能现实我们的需求。

from multiprocessing import Process

def func1(args):

    print('*'*args)

if __name__ == '__main__':

    p_list = [] #创建一个空列表用来存放等会生产的进程对象

    for i in range(10):

        p1 = Process(target=func1,args=(i,))

        p_list.append(p1)#将每个进程对象依次存放进列表中

        p1.start()

    [i.join() for i in p_list]  # 运用列表推导式：循环列表，依次对列表中的进程对象执行join()方法。之前所有进程必须在这里执行完才能执行下面的代码。

    print('执行完毕！')

结果1：　　结果2：

巴特西

python_并发编程——多进程

最新文章

热门文章