join()
同样的，如果你期望强制等待一个守护进程的结束，可以增加join()函数。还是上面的代码，示例如下：
import multiprocessing import time def worker(): print(multiprocessing.current_process().name, "start") time.sleep(1) print(multiprocessing.current_process().name, "end") def worker2(): print(multiprocessing.current_process().name, "start") time.sleep(2) print(multiprocessing.current_process().name, "end") if __name__ == "__main__": p1 = multiprocessing.Process(name='p1', target=worker) p2 = multiprocessing.Process(name='p2', target=worker2, daemon=True) p3 = multiprocessing.Process(name='p3', target=worker2, daemon=True) p1.start() p2.start() p3.start() p1.join() p2.join() p3.join()
运行之后，和设置进程名的运行结果一样，这里不在展示。唯一与守护进程代码的区别就是最后三行join()函数代码。当然，也可以像线程一样，给join()函数传入一个时间，超过这个时间，主进程不再等待。
强制结束进程
如果一个进程已经挂起或者不小心进入了死锁状态，那么这个时候，我们往往会强制的结束进程。对一个进程对象调用terminate()会结束子进程。示例如下：
import multiprocessing import time def worker(): print(multiprocessing.current_process().name, "start") time.sleep(5) print(multiprocessing.current_process().name, "end") if __name__ == "__main__": p1 = multiprocessing.Process(name='p1', target=worker) p1.start() print("是否还在运行", p1.is_alive()) p1.terminate() print("是否还在运行", p1.is_alive()) p1.join() print("是否还在运行", p1.is_alive())
运行之后，输出如下：
终止进程后要使用join()函数等待进程的退出。使进程管理代码有足够的时间更新对象的状态，以反应进程已经终止。
进程退出状态码
进程退出时，生成的状态码可以通过exitcode属性访问。下表就是其状态码的取值范围以及其意义：
| 退出码 | 含义 |
| 0 | 未生成任何错误 |
| >0 | 进程有一个错误，并以该错误码退出 |
| <0 | 进程以一个-1*exitcodde信号结束 |
测试如下：
import multiprocessing import time def worker(): print(multiprocessing.current_process().name, "start") time.sleep(5) print(multiprocessing.current_process().name, "end") if __name__ == "__main__": p1 = multiprocessing.Process(name='p1', target=worker) p2 = multiprocessing.Process(name='p2', target=worker) p1.start() p2.start() print("是否还在运行", p1.is_alive()) p1.terminate() print("是否还在运行", p1.is_alive()) print(p1.exitcode) p1.join() print("是否还在运行", p1.is_alive()) print(p1.exitcode) time.sleep(5.5) print(p2.exitcode)
运行之后，效果如下：
可以看到，强制退出的进程状态码为负数，正常退出的进程状态码为0。
日志
调试并发问题时，如果能够访问multiprocessing所提供对象的内部状态，那么这会很有用。在实际的项目中，我们可以使用一个方便的模块级函数启用日志记录，它使用logging建立一个日志记录器对象，并增加一个处理器，使日志消息被发送到标准错误通道。
示例如下：
import multiprocessing import logging import sys def worker(): print("运行工作进程") sys.stdout.flush() if __name__ == "__main__": multiprocessing.log_to_stderr(logging.DEBUG) p1 = multiprocessing.Process(name='p1', target=worker) p1.start() p1.join()
运行之后，效果如下：
派生进程
与线程一样，我们可以自定义进程，而不必只是传入一个函数进行进程的创建。
创建的进程的方式也是派生自进程类即可。示例如下：
import multiprocessing class WorkerProcess(multiprocessing.Process): def run(self): print(self.name) return if __name__ == "__main__": for i in range(5): p = WorkerProcess() p.start() p.join()
运行之后，效果如下：
multiprocessing库的进程知识与threading一样长，因为本篇的内容已经够长了，剩下的知识我们将在下一篇博文中接着讲解。
