测试 ProcessPoolExecutor 异步结果的获得

test_multiprocess_res.py

#!/usr/bin/env python3
# -*- coding: utf-8 -*-


"""测试通过 concurrent.futures.ProcessPoolExecutor 获取多进程执行的结果.
"""

import pprint
from concurrent.futures import ProcessPoolExecutor, as_completed


def ret_name(name):
    print(name)
    
    return name


def controller():
    names = ['flyer', 'flx', 'mafei', 'math', 'fei']

    with ProcessPoolExecutor() as executor:
        futures = [executor.submit(ret_name, name) for name in names]

    results = [future.result() for future in futures]
    print('Results are:')
    pprint.pprint(results)


if __name__ == '__main__':
    controller()