进程池

2019-02-17 01:53:04来源:博客园 阅读 ()

新老客户大回馈,云服务器低至5折

 

 

from multiprocessing import Pool
import os
import time


def worker(num):
    print("task <%s> is runing <%d>" % (os.getpid(), num))
    time.sleep(2)


def main():
    # 定义一个进程池,最大进程数3
    po = Pool(3)

    for i in range(0, 10):
        # Pool().apply_async(要调用的目标,(传递给目标的参数元祖,))
        # 每次循环将会用空闲出来的子进程去调用目标
        po.apply_async(worker, args=(i,))

    print("---start---")
    # 关闭进程池,关闭后po不再接收新的请求
    po.close()
    # 等待po中所有子进程执行完毕,必须放在close语句之后
    po.join()
    print("---end---")


if __name__ == '__main__':
    main()

 


原文链接:https://www.cnblogs.com/Selling-fish-bears/p/10375041.html
如有疑问请与原作者联系

标签:

版权申明:本站文章部分自网络,如有侵权,请联系:west999com@outlook.com
特别注意:本站所有转载文章言论不代表本站观点,本站所提供的摄影照片,插画,设计作品,如需使用,请与原作者联系,版权归原作者所有

上一篇:Python分析 oj 网的题目难度和通过率的关系

下一篇:Python之父重回决策层,社区未来如何发展?