欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

python__系统 : 进程

程序员文章站 2022-10-03 11:47:45
在类unix操作系统下,可以用 os.fork() 创建一个新的进程,windows系统不可以: 在执行了 os.fork() 这一句之后,会有两个进程同时向下执行, 返回的 ret 分别是 0(子进程)的 和 大于0(父进程)的 , getpid() 是获取当前进程的pid getppid() 是 ......

在类unix操作系统下,可以用 os.fork() 创建一个新的进程,windows系统不可以:

import os

ret = os.fork()
print('ret=%d' % ret)

if ret == 0:
    print('这是子进程:%d,继承自:%d' % (os.getpid(), os.getppid()))
else:
    print('这是父进程:%d' % os.getpid())

>>>ret=0
   这是子进程:1537,继承自:1536
   ret=1537
   这是父进程:1536

在执行了 os.fork() 这一句之后,会有两个进程同时向下执行, 返回的 ret 分别是 0(子进程)的  和  大于0(父进程)的 ,

getpid() 是获取当前进程的pid getppid() 是获取父进程的 pid 所以可以看出子进程 1537继承自1536.

注意父进程的结束并不会导致子进程的停止.

所以,一般,用 multiprocessing 模块来创建一个新的进程,多系统通用:

from multiprocessing import Process
import  time
import test2

if __name__ == '__main__':

    p = Process(target=test2.test)
    p.start()

    while True:
        print('----mian----')
        time.sleep(1)

>>>----mian----
   ----test----
   ----mian----
   ----test----

target 里面是子进程调用对象的名称. (函数放在这个文件里面执行有bug,所以放在了 test2.py 文件里面,不加if __name__ == '__main__': 这一行也会有bug)

Process语法结构如下:

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

  • target:表示这个进程实例所调用对象;

  • args:表示调用对象的位置参数元组;

  • kwargs:表示调用对象的关键字参数字典;

  • name:为当前进程实例的别名;

  • group:大多数情况下用不到;

Process类常用方法:

  • is_alive():判断进程实例是否还在执行;

  • join([timeout]):是否等待进程实例执行结束,或等待多少秒;

  • start():启动进程实例(创建子进程);

  • run():如果没有给定target参数,对这个对象调用start()方法时,就将执行对象中的run()方法;

  • terminate():不管任务是否完成,立即终止;

Process类常用属性:

  • name:当前进程实例别名,默认为Process-N,N为从1开始递增的整数;

  • pid:当前进程实例的PID值;

还有一种方式创建进程,就是Process子类创建子进程, 因为 p.start() 是调用 p的run() 方法,所以需要重写run方法:

class MyProcess(Process):

    def run(self):
        while True:
            print('----1----')
            time.sleep(1)


if __name__ == '__main__':

    p = MyProcess()
    p.start()

    while True:
        print('main')
        time.sleep(1)

>>>main
   ----1----
   main
   ----1----

当然,还有更加简单的方法创建进程.那就是进程池:

if __name__ == '__main__':

    pool = Pool(3) #最多三个进程

    for i in range(10):
        pool.apply_async(test2.test, (i,))  #添加任务    如果换成 pool.apply()   那么会以堵塞的方式添加任务,一个进程执行完才能添加下一个进程

    pool.close() #关闭进程池,不能再添加任务
    pool.join()  #等待进程池里的任务完成

需要注意的是,进程池并不和Process一样会等待子进程的结束,而是任务完成之后马上结束主进程,所以需要 pool.join() 等待子进程结束.