concurrent.futures 相关问题

concurrent.futures是一个Python模块,它为异步执行callables提供了一个高级接口。

使用concurrent.futures.ThreadPoolExecutor处理列表字典的每个元素

假设我有一本字典,例如 字典 = {A:[1,2,3], B:[4,5,6], C:[7,8,9], ......} 我想依次处理特定键列表中的每个元素,但各个键可能是

回答 2 投票 0

安装并发包并行处理异常

我正在尝试将警告捕获为并行运行的函数中的异常。根据这篇文章,并发包非常适合并行函数中的错误处理(我第一次尝试

回答 1 投票 0

concurrent.futures.ThreadPoolExecutor -- 检查状态

我有一个与此几乎相同的问题: 检查 `concurrent.futures.ThreadPoolExecutor` 然而,有一个转折。我没有使用 executor.submit,而是使用地图方法...

回答 1 投票 0

当所有ThreadPoolExecutor线程都忙时,如何等待?

我对ThreadPoolExecutor如何工作的理解是,当我调用#submit时,任务被分配给线程,直到所有可用线程都忙,此时执行器将任务放入q...

回答 2 投票 0

并发 Future 与 Asyncio 的区别

我尝试通过异步执行来优化Python代码。为了做到这一点,我尝试了 asyncio 和并发.futures 库。 这是我的代码: async def get_rds_instances(会话、区域、engine_ty...

回答 1 投票 0

ThreadPoolExecutor asyncio 类似物?

我曾经在我的项目中使用concurrent.futures.ThreadPoolExecutor,在单独的线程中运行我的同步函数。 现在我主要使用 asyncio 异步代码,但我有一个

回答 1 投票 0

并行化、多重处理、CSV 编写器

我有一个名为 term_list 的巨大字符串列表,我在名为 run_mappers() 的函数中逐一处理它们。其中一个参数是 csv_writer 对象。我将结果附加到名为 from_mapper 的列表中...

回答 1 投票 0

Android:为 Futures 和 AppSearch Android 12 导入哪些依赖项

我正在关注本教程 https://developer.android.com/guide/topics/search/appsearch#groovy 使用 AppSearch 制作示例应用程序。但是,当我获得架构部分时,我对 &

回答 1 投票 0

`ThreadPoolExecutor.shutdown` 不起作用,代码无限期地卡住

如果在其中一个线程执行期间发生某种异常,我需要能够暂停所有线程,或者立即终止所有线程。 从并发.futures 导入

回答 1 投票 0

Java:取消未来

我正在使用 ThreadPoolExecutor.submit 创建多个 future 以并行写入数据库。 for(BusinessElement el : elements){ list.add(threadPoolExecutor.submit(() -> createElement(el...

回答 1 投票 0

我正在使用带有线程的 subprocess.Popen 类,但它对我不起作用

我有以下文件: 平.py: 从utilities.env导入PACKET_COUT、PING_TIME、MAX_WORKERS_COUNT 从utilities.cmds导入create_ping_cmd 从子进程导入 Popen、PIPE、DEVNULL、TimeoutE...

回答 1 投票 0

ProcessPoolExecutor 可以与 Python 中的产量生成器一起使用吗?

我有一个python脚本,旨在处理一些大文件并将结果写入新的txt文件中。我将其简化为代码示例 1。 代码示例1: 从并发.futures 导入 ProcessPoolExec...

回答 1 投票 0

在 FastAPI 端点中调用并发.futures.ThreadPoolExecutor 是否危险?

我有以下测试代码: 导入并发期货 导入 urllib.request URLS = ['http://www.foxnews.com/', 'http://www.cnn.com/', 'http://europe.wsj.com/', 'http://...

回答 1 投票 0

如何使用run_in_executor来管理ProcessPoolExecutor

我有一个 FastAPI 程序,它接收大约 30-100 个请求/秒的请求内容,大小为 1Kb-1Mb,并且我正在对内容运行正则表达式匹配,正则表达式是空白容忍的,也就是说我可以 .. .

回答 1 投票 0

如何使用tqdm和ProcessPoolExecutor

我正在创建一个程序,可以处理有时非常大的文件(GB 级)。这需要很多时间。一开始我尝试使用ThreadPoolExecutor,相对提高了速度。对于

回答 1 投票 0

ThreadPoolExecutor 线程数

我正在尝试使用 futures backport 包在 Python 中使用 ThreadPoolExecutor。然而,问题是所有线程都是同时执行的,因此没有实际的池化计划...

回答 1 投票 0

在Python的ThreadPoolExecutor中重试失败的futures

我想用Python的concurrent.futures.ThreadPoolExecutor实现重试逻辑。我想要以下属性: 一旦失败,新的 future 就会被添加到工作队列中。 重试了...

回答 3 投票 0

如何使用concurrent.futures获取url和嵌套页面url?

我正在尝试收集网页中的锚标记 href 值和嵌套 url,并对每个此类 url 重复该操作。 我想减少使用并发获取网址的时间。 导入

回答 1 投票 0

如何使用concurrent.futures获取锚点href值和嵌套页面锚点href值?

我正在尝试使用并发.futures 获取锚标记 href 值和嵌套 url? 我想减少使用下面的代码获取网址的时间。 使用下面的方法获取 URL 需要一些时间

回答 1 投票 0

我想使用多线程从单个URL获取锚标记值和嵌套锚标记值

我尝试使用下面的代码获取以下 URL https://www.tradeindia.com/ 的锚标记 href 和嵌套锚标记值,但不会生成确切的输出。下面的代码只能获取单页...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.