多进程(二)

2021/7/11 7:09:28

本文主要是介绍多进程(二),对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!

通过mutiprocessing创建进程

from multiprocessing import Process
import time

def run_proc():
    """子进程要执行的代码"""
    print("子进程的进程号%d" % os.getpid())
    while True:
        print("----2----")
        time.sleep(1)

if __name__=='__main__':
    print("主进程的进程号%d" % os.getpid())
    p = Process(target=run_proc)
    p.start()
    while True:
        print("----1----")
        time.sleep(1)

在这里插入图片描述

Process语法结构

Process([group [, target [, name [, args [, kwargs]]]]])

target:如果传递了函数的引用,可以认为这个子进程就执行这里的代码
args:给target指定的函数传递的参数,以元组的方式传递
kwargs:给target指定的函数传递命名参数
name:给进程设定一个名字,可以不设定
group:指定进程组,大多数情况下用不到

Process创建的实例对象的常用方法:

start():启动子进程实例(创建子进程)
is_alive():判断进程子进程是否还在活着
join([timeout]):是否等待子进程执行结束,或等待多少秒
terminate():不管任务是否完成,立即终止子进程

Process创建的实例对象的常用属性:

name:当前进程的别名,默认为Process-N,N为从1开始递增的整数
pid:当前进程的pid(进程号)

向子进程传递参数

from multiprocessing import Process
import os
from time import sleep

def run_proc(name, age, **kwargs):
    for i in range(10):
        print('子进程运行中,name= %s,age=%d ,pid=%d...' % (name, age, os.getpid()))
        print(kwargs)
        sleep(0.2)

if __name__=='__main__':
    p = Process(target=run_proc, args=('test',18), kwargs={"m":20})
    p.start()
    sleep(1)  # 1秒中之后,立即结束子进程
    p.terminate()
    p.join(

在这里插入图片描述

不同进程之间不共享全局变量

# -*- coding:utf-8 -*-
from multiprocessing import Process
import os
import time

nums = [11, 22]

def work1():
    """子进程要执行的代码"""
    print("in process1 pid=%d ,nums=%s" % (os.getpid(), nums))
    for i in range(3):
        nums.append(i)
        time.sleep(1)
        print("in process1 pid=%d ,nums=%s" % (os.getpid(), nums))

def work2():
    """子进程要执行的代码"""
    print("in process2 pid=%d ,nums=%s" % (os.getpid(), nums))

if __name__ == '__main__':
    p1 = Process(target=work1)
    p1.start()
    p1.join()  # 主进程阻塞,等待子进程p1执行完毕

    p2 = Process(target=work2)
    p2.start()

在这里插入图片描述



这篇关于多进程(二)的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!


扫一扫关注最新编程教程