python 进程池

用户5760343

发布于 2019-07-30 10:57:24

6570

发布于 2019-07-30 10:57:24

文章被收录于专栏：sktj

import multiprocessing import time import os import random

def test1(msg): t_start = time.time() print("%s开始执行，进程号为%d" % (msg, os.getpid())) time.sleep(random.random() * 2) t_stop = time.time() print("%s执行完成，耗时%.2f" % (msg, t_stop - t_start))

if name == "main":

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

    print("-----start-----")

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

    print("-----end-----")

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2019.07.28 ，如有侵权请联系 cloudcommunity@tencent.com 删除

import