ret_values?=?[]

def?thread_func(*args):
????...
????value?=?...
????ret_values.append(value)

from?threading?import?Thread

threads?=?[None]?*?10
results?=?[None]?*?10

def?foo(bar,?result,?index):
????result[index]?=?f"foo-{index}"

for?i?in?range(len(threads)):
????threads[i]?=?Thread(target=foo,?args=('world!',?results,?i))
????threads[i].start()

for?i?in?range(len(threads)):
????threads[i].join()

print?("?".join(results))

from?threading?import?Thread


def?foo(arg):
????return?arg


class?ThreadWithReturnValue(Thread):
????def?run(self):
????????if?self._target?is?not?None:
????????????self._return?=?self._target(*self._args,?**self._kwargs)

????def?join(self):
????????super().join()
????????return?self._return


twrv?=?ThreadWithReturnValue(target=foo,?args=("hello?world",))
twrv.start()
print(twrv.join())?#?此處會打印 hello world。

import?concurrent.futures


def?foo(bar):
????return?bar


with?concurrent.futures.ThreadPoolExecutor(max_workers=10)?as?executor:
????to_do?=?[]
????for?i?in?range(10):??#?模擬多個任務(wù)
????????future?=?executor.submit(foo,?f"hello?world!?{i}")
????????to_do.append(future)

????for?future?in?concurrent.futures.as_completed(to_do):??#?并發(fā)執(zhí)行
????????print(future.result())