Python-使用进程池并发请求

import requests
from loggers import logger
import multiprocessing


def func():
    try:
        for i in range(1):
            response = requests.get(
                'http://localhost:63000/')
            print(response.status_code, response.text)
    except Exception as error:
        logger.exception(error)


if __name__ == "__main__":
    pool = multiprocessing.Pool(processes=56)
    for i in range(100000):
        pool.apply_async(func)
    pool.join()

要提交工作的时候，有几个货色能够用：

• apply
• apply_async
• map
• map_async

apply 和 map 不能并行，所以毫无用处

apply_async 和 map_async 有什么区别？

map_async 一次只能穿一个参数，所有没有用理论用途
apply_async 能够一次传多个参数，所以最有用

参考资料：
apply_async

喜欢 (0)赏

[搞代码]

分享 (0)