我正在学习如何在executor.map()和executor.submit()中使用并发。我有一个包含20个url的列表，并希望同时发送20个请求，问题是.submit()返回结果的顺序不同于从一开始给定的列表。我读到过map()可以满足我的需求，但我不知道如何用它来编写代码。问:有没有等同于下面代码的map()代码块，或者可以按照给定列表的顺序对submit()中的结果列表进行排序的排序方法？executor:
# Start the load operations and
浏览 742提问于2020-08-21得票数 2
回答已采纳
使用multiprocessing.pool，我可以拆分一个输入列表，以便沿着多个CPU并行处理单个函数。如下所示： return x*x
pool = Pool(processes=4) pool.close()但是，这不允许在不同的处理器上运行不同的函数。如果我想这样做，平行地/同时：
foo
浏览 0提问于2019-06-06得票数 1
回答已采纳
我正在尝试理解如何使用Python3.2.2中的concurrent.futures模块，并一直在使用文档中的示例。当我试图运用我的理解时，我自己的例子就失败了。我希望有人能帮我走上正轨！我希望能够设置许多并发但异步运行的进程。我的流程不返回任何东西。concurrent.futures.ProcessPoolExecutor() as executor: executor.submit那么，在进程池中运行Python进程的正确方法是什么？我不想使用
浏览 0提问于2011-11-10得票数 5
但是，executor.map()的结果是一个生成器，因此为了实际收集已处理的结果，我遍历该生成器。这是非常非常慢(小时)，部分是因为它是单一的核心，部分是因为循环。实际上，它比my_function()中的实际处理要慢得多import concurrent
df = pd.DataFrame({'col1': [], 'col
浏览 0提问于2018-10-30得票数 1
回答已采纳
我已经构建了一个函数，在这里我想利用Python中的多线程。这个函数有两个参数:一个列表类型的参数(其中我利用多线程)和一个不可迭代的变量。conn.cursor(as_dict=True)
results = executor.map
浏览 5提问于2022-07-15得票数 0
回答已采纳
到目前为止，并发性在10到20 requests.But上运行良好，目前外部api实现的并发限制为100，如果并发性超过100，我将从api响应中得到一些服务器错误。因此，我们的目标是用并发性调用外部api，但不要达到限制。通过设计，我们无法控制用户可以从前端提交多少个参数。
这个想法是用户将提交来自前端的params的动态数量。我的问题是，什么是处理并发性的有效方法，以动态处理超过params限制的事务？.] // lets say 200 keywords from user fo
浏览 1提问于2022-06-30得票数 0
回答已采纳
我编写了一个python代码，它将原始数据(STM显微镜)转换为png格式，并在我的Macbook Pro上完美地运行。下面是简化的Python代码： for dir in dirs:
fpath = path +'/'现在，我想使用多线程技术(使用“并发未来”库)来减少处理时间。试图使用“PythonThinging教程”上的YouTube视频来修改python代码。但是我必须在ex
浏览 0提问于2021-08-25得票数 0
回答已采纳
func(task):executor = ThreadPoolExecutor(4)executor = ThreadPoolExecutor(4)executor = ThreadPoo
浏览 3提问于2015-02-09得票数 5
3回答
[] for pattern, res in zip(patterns, executor.map我想要做的事情和示例代码之间唯一真正的区别是，我的函数有7个参数，我不知道如何做，花了半天时间在上面。[] for pattern, res in zip(patterns, executor.map</e
浏览 5提问于2014-02-19得票数 4
回答已采纳
因此，我想用多线程处理下面的带有并发期货的代码，但是到目前为止，我尝试过的任何东西似乎都不起作用。因此，每个文件的名称和链接位于相同的位置。x.append(i)
executor.submitexecutor.map")开始和结
浏览 3提问于2021-10-06得票数 1
回答已采纳
2回答
运行python3 main.py :80/时，将返回一个TypeError: 'module' object is not iterable executor.map(scan, ipaddress)Traceback (most recent call
浏览 0提问于2020-08-21得票数 0
回答已采纳
1回答
我在python中为Scapy生成数据包的函数一次只使用1个CPU，这一点让我很头疼。我一直在寻找多进程，但我真的不知道如何实现它。我也尝试使用一些ThreadPool，但结果是一样的。
浏览 0提问于2015-10-29得票数 0
finviz.get_stock(ticker)print(AAPL)使用finviz模块和finviz.get_stockwith concurrent.futures.ProcessPoolExecutor() as executor: executor.map
浏览 2提问于2021-05-07得票数 0
回答已采纳
我想使用python的concurrent.futures.ThreadPoolExecutor并发地调用它们。有没有办法使用Executor调用它们，并确保它们按提交的顺序返回？我知道使用Executor.map可以做到这一点，但我希望并行化两个独立的函数，而不是一个具有可交互输入的函数。 with ThreadPoolExecutor() as executor: futur
浏览 2提问于2018-12-20得票数 0
1回答
我正在尝试将我的脚本从使用线程转换为更酷的多处理(使用Python3.2和concurrent.futures，但是这段代码崩溃了 for result in executor.map(lambda h:在阅读时，我认为问题在于不可能将lambda函数作为executor.map()的参数，为了创建executor.map()，我需要开发一个单
浏览 1提问于2012-02-03得票数 3
回答已采纳
我惊讶地发现： results = list(executor.map(f, iterable))with concurrent.futures.ThreadPoolExecutor(max_workers=4) as executor:产生不同的结果。我
浏览 409提问于2013-12-30得票数 84
回答已采纳
我定义了一个函数FactorTest.py，它接收变量x并以并行方式调用函数a():return x+1, b():return x+2, c():return x+3 and d():return x+4。有没有办法实现这一点？这一点是以并行的方式进行的。
浏览 1提问于2021-03-01得票数 0
我想要类似于executor.map的东西，但当我迭代结果时，我想按照完成的顺序迭代它们，例如，首先完成的工作项应该首先出现在迭代中，这样迭代就会阻止序列中的每一个工作项还没有完成。您能解释一下我如何在executor.map中使用executor.map吗？executor.map是我在使用未来时最有用和最简洁的工具，而且我不愿意手动使用Future对象。
浏览 8提问于2013-04-29得票数 30
回答已采纳
云服务器
ICP备案
云点播
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号