from multiprocessing import Pool
import time
import osdef test():print("---进程池中的进程---pid=%d,ppid=%d--"%(os.getpid(),os.getppid()))for i in range(3):print("----%d---"%i)time.sleep(1)return "hahah"def test2(args):print("---callback func--pid=%d"%os.getpid())print("---callback func--args=%s"%args)pool = Pool(3)
pool.apply_async(func=test,callback=test2)time.sleep(5)print("----主进程-pid=%d----"%os.getpid())
运行结果:---进程池中的进程---pid=9401,ppid=9400--
----0---
----1---
----2---
---callback func--pid=9400
---callback func--args=hahah
----主进程-pid=9400----
版权声明:本站所有资料均为网友推荐收集整理而来,仅供学习和研究交流使用。
工作时间:8:00-18:00
客服电话
电子邮件
admin@qq.com
扫码二维码
获取最新动态