Python concurrent.futures - 未调用方法

Question

我正在使用以下代码运行本地 django 服务器:

import concurrent.futures

media_download_manager = concurrent.futures.ProcessPoolExecutor(max_workers=2)

def hello():
    print "hello"


for i in range(1, 1000):
    print "submitting task "
    media_download_manager.map(hello)

我正在初始化一个进程池执行器来接受具有 2 个工作线程的任务。任务正在提交，但处理提交任务的工作线程似乎没有触发。

接着是控制台输出:

submitting task 1
submitting task 2
submitting task 3
submitting task 4
submitting task 5
submitting task 6
submitting task 7
submitting task 8
submitting task 9
Performing system checks...

System check identified no issues (0 silenced).
October 15, 2016 - 06:09:31
Django version 1.8.4, using settings 'Learn.settings'
Starting development server at http://192.168.1.3:8000/
Quit the server with CONTROL-C.

我在这里错过了什么？

Answer 1

The Executor.map function旨在将参数从可迭代对象传递给映射函数。您没有提供任何可迭代对象，因此它不会运行(并且您的函数不接受任何参数，因此如果您提供了可迭代对象，它会在传递太多参数时失败)。

如果你只是想多次不带参数地运行那个函数，调用submit ; map 旨在传递参数并从返回的结果中累积结果，而不仅仅是为了产生副作用而运行某些东西(它是一种函数式编程工具，函数式代码通常没有副作用)。

固定代码为:

futures = []
for i in range(1, 1000):
    print "submitting task "
    futures.append(media_download_manager.submit(hello))
concurrent.futures.wait(futures)  # Wait for all tasks to finish