python__系统 : 进程

Posted 2020-11-07 cccy

在类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() 等待子进程结束.