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