如何在进程池中实现并发，并且返回值是按照顺序返回？

1.回调函数 add_done_callback()

但是返回结果是无序的。

import time
import random
from concurrent.futures import ProcessPoolExecutor
def func1(n):
    time.sleep(random.random())
    print('in func1 %s'%n)
    return n*2

def call_back(arg):
    print(arg.result())

if __name__ == '__main__':
    p = ProcessPoolExecutor(4)
    for i in range(10):
        ret = p.submit(func1,i)
        ret.add_done_callback(call_back)#是乱序的

运行结果：

2. 运用列表：

import time
import random
from concurrent.futures import ProcessPoolExecutor
def func1(n):
    time.sleep(random.random())
    print('in func1 %s'%n)
    return n*2

def call_back(arg):
    print(arg.result())

if __name__ == '__main__':
    p = ProcessPoolExecutor(4)
    # for i in range(10):
    #     ret = p.submit(func1,i)
    #     ret.add_done_callback(call_back)#是乱序的
    ret_l = []
    for i in range(10):
        ret = p.submit(func1, i)
        ret_l.append(ret)#实现了该列表的顺序不是乱序的，在for循环列表中直接放对象
        # print(ret)
    for r in ret_l:
        call_back(r)

运行结果：

 3.

import time
import random
from concurrent.futures import ProcessPoolExecutor
def func1(n):
    time.sleep(random.random())
    print('in func1 %s'%n)
    return n*2

def call_back(arg):
    print(arg.result())

if __name__ == '__main__':
    p = ProcessPoolExecutor(4)
    # for i in range(10):
    #     ret = p.submit(func1,i)
    #     ret.add_done_callback(call_back)#是乱序的
    ret_l = []
    for i in range(10):
        ret = p.submit(func1, i)
        call_back(ret)
        # ret_l.append(ret)#实现了该列表的顺序不是乱序的，在for循环列表中直接放对象
        # print(ret)
    # for r in ret_l:
    #     call_back(r)

运行结果：

猜想的 不一定对，call_back（ret）接受的是对象  但是call_back函数需要打印ret.result()  使得程序阻塞。