Python多进程编程之结束进程(多进程共享变量)

一、多进程之间共享变量以及结束进程terminate()命令

import time
from multiprocessing import Process, Value, Array

def make_calculation1(var1,n):
    s = n
    while 1:
        s = s + 1
        var1.value = s
        time.sleep(0.2)
        print('子进程1', var1.value)

def make_calculation2(var2,n):
    s=10
    for i in range(n):
        s = s + i
    var2.value = s
    print('子进程2', var2.value)

def make_calculation3(var1,var2):
    for _ in range(3):
        print('子进程3=', var1.value, var2.value)
        time.sleep(0.2)

if __name__  == '__main__':
    start_time = time.time()
    n = 101
    shared_var1 = Value('i', 0)
    shared_var2 = Value('i', 0)

    p1 = Process(target=make_calculation1, args=(shared_var1, n))
    p2 = Process(target=make_calculation2, args=(shared_var2, n))
    p3 = Process(target=make_calculation3, args=(shared_var1, shared_var2))
    p3.start()
    p1.start()
    p2.start()
    #p1.join()
    #p2.join()
    #p3.join()
    print('主进程=', shared_var1.value, shared_var2.value)
    time.sleep(2)
    p1.terminate()    # 结束子进程
    p1.join()         # 等待子进程结束，需要有此句，否则会成为死进程！
    print('主进程=', shared_var1.value, shared_var2.value)
    print('完成用时', time.time()-start_time)

输出结果:通过共享变量，函数1和2的运行结果顺利传递到函数3，并用terminate()命令结束死循环的进程1，p1.terminate() # 结束子进程，p1.join() # 等待子进程结束，需要有此句，否则会成为死进程！

D:\pyproject\pythonProject\.venv\Scripts\python.exe D:\pyproject\pythonProject\test6.py
主进程= 0 0
子进程2 5060
子进程3= 102 5060
子进程1 102
子进程3= 103 5060
子进程1 103
子进程3= 104 5060
子进程1 104
子进程1 105
子进程1 106
子进程1 107
子进程1 108
子进程1 109
子进程1 110
主进程= 111 5060
完成用时 2.052525758743286
进程已结束，退出代码为 0

注意事项：

要停止一个进程实例，可以调用方法 terminate:

p.terminate()

但是通过执行系统命令ps查看停止后的进程，会发现，直接调用terminate方法停止的进程变成了一个僵尸进程（defunct），只能等待主程序推出，这个僵尸进程才会消失！

通过再terminate后添加一次调用join方法等待进程真正结束，就能避免出现僵尸进程：

p.join()