这篇文章主要为大家介绍了python 进程池的两种不同实现示例，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪

方式一：使用 multiprocessing 库

from loguru import logger
import multiprocessing
def start_request(message: str) -> int:
    try:
        logger.debug(message)
    except Exception as error:
        logger.exception(error)
if __name__ == "__main__":
    pool = multiprocessing.Pool(processes=2)
    for message in ['haha', 'hehe']:
        pool.apply_async(start_request, (message,))
    pool.close()
    pool.join()

方式二：使用 concurrent.futures 的 ProcessPoolExecutor

from loguru import logger
import multiprocessing
from concurrent.futures import ProcessPoolExecutor
def start_request(message: str) -> int:
    try:
        logger.debug(message)
    except Exception as error:
        logger.exception(error)
if __name__ == "__main__":
    pool = ProcessPoolExecutor(
        max_workers=2
    )
    for message in ['haha', 'hehe']:
        pool.submit(start_request, message)
    pool.shutdown(wait=True)

以上就是python 进程池的两种不同实现示例的详细内容，更多关于python 进程两种实现的资料请关注其它相关文章！

原文链接：https://segmentfault.com/a/1190000043747872.