Skip to main content
 首页 » 编程设计

Python concurrent.futures之未调用方法

2025年05月04日23dyllove98

我正在使用以下代码运行本地 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. 

我在这里错过了什么?

请您参考如下方法:

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