并发.用不同的参数执行两个不同的函数

Question

我正在尝试使并发。用不同的参数执行两个不同的函数。然而，它并不成功。所需的功能如下:

def func1(para1, para2):
time.sleep(para1)
print(para2)
def func2(para1, para2, para3):
time.speep(para2)
print(para2+para3)

许多在线教程演示了多次使用同一个函数，每个函数只有一个参数。我没有运气运行2个不同的函数与不同的参数运行使用concurrent.future。任何想法?

根据James的回复修复代码:

from concurrent.futures import ThreadPoolExecutor, wait
import time
start_time = time.time()
def fn_a(s,v):
t_sleep = s
print("function a: Wait {} seconds".format(t_sleep))
time.sleep(t_sleep)
ret = v * 5 # return different results
print(f"function a: return {ret}")
return ret
def fn_b(s,v):
t_sleep = s
print("function b: Wait {} seconds".format(t_sleep))
time.sleep(t_sleep)
ret = v * 10 # return different results
print(f"function b: return {ret}")
return ret
def fn_c(s,v):
t_sleep = s
print("function c: Wait {} seconds".format(t_sleep))
time.sleep(t_sleep)
ret = v * 20 # return different results
print(f"function c: return {ret}")
return ret
output = []
with ThreadPoolExecutor() as executor:
futures = []
futures.append(executor.submit(fn_a, 5, 1.1))
futures.append(executor.submit(fn_b, 4, 2.2))
futures.append(executor.submit(fn_c, 8, 3.3))
complete_futures, incomplete_futures = wait(futures)
for f in complete_futures:
output.append(f.result())
print(str(f.result()))
elapsed = (time.time() - start_time)
print(f"Total time of execution {round(elapsed, 4)} second(s)")
print("Output is:",output)

Answer 1

你可以按照你想要的参数顺序将函数提交给你的执行器。

import time
from concurrent.futures import ThreadPoolExecutor
def func1(para1, para2):
time.sleep(para1)
print(para2)
def func2(para1, para2, para3):
time.sleep(para1)
print(para2+para3)
with ThreadPoolExecutor(2) as ex:
futures = []
futures.append(ex.submit(func1, 3, 'hello'))
futures.append(ex.submit(func2, 2, 'world', 'blah'))
# prints:
worldblah
hello