标签：concurrent.futures
-
如何在python 3中将队列与将来的并发ThreadPoolExecutor一起使用？ - python
我正在使用简单的线程模块来执行并发作业。现在，我想利用并发期货模块的优势。有人可以给我一个使用并发库队列的例子吗？ 我收到TypeError：“队列”对象不可迭代我不知道如何迭代队列 代码段： def run(item): self.__log.info(str(item)) return True <queue filled here> wit […]
-
使用Concurrent.Futures模块作为ThreadPool调用时，Python-get函数的返回值 - python
我使用Concurrent.Futures模块创建了一个ThreadPool。我创建了线程，并且一切正常。 但是现在我有了一个函数，希望使其与线程并行，问题是我需要每个线程应运行的函数的返回值，并且不确定使用Futures threadPool模块时如何获取它。有办法吗？ 参考方案 您对result()的理解是绝对错误的。从doc: 结果(超时=无) 返回调 […]
-
存储结果ThreadPoolExecutor - python
我对使用“ concurrent.futures”进行并行处理还很陌生，并且正在测试一些简单的实验。我编写的代码似乎有效，但是我不确定如何存储结果。我试图创建一个列表（“ futures”）并将结果附加到该列表中，但这会大大减慢该过程。我想知道是否有更好的方法可以做到这一点。谢谢。 import concurrent.futures import time […]
-
什么时候不使用asyncio有意义？ - python
在什么情况下会在asyncio上使用一个线程或执行程序（使用线程）？ 随着我使用Python（CPython）的经验的进步，它集中于优化工作脚本以批量执行某种形式的Web服务调用并处理响应。但是，经过几代脚本构建之后，我发现自己想知道为什么我不使用最新的脚本？ 请允许我在下面提供一些背景信息... 问题：从服务器A向客户端B请求N个文件，进行处理并将其保存到 […]