concurrent.futures 相关问题

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

concurrent.futures 关闭后等待时间较长

我有一个 URL 列表,我正在尝试从中获取 JSON 数据。我正在查看包含 10,000 多个项目的列表,因此速度对我来说至关重要。这在串行处理中花费了很长时间,所以我选择使用会话......

回答 1 投票 0

如果一个线程出现异常,如何停止所有线程?

我目前正在使用python的concurrent.futures库运行一个函数。它看起来像这样(我使用的是 Python 3.10.1 ): 以 concurrent.futures.ThreadPoolExecutor() 作为执行器: 未来的结果...

回答 2 投票 0

一旦期货开始,你如何杀死它们?

我正在使用新的并发.futures 模块(它也有一个 Python 2 向后移植)来执行一些简单的多线程 I/O。我无法理解如何干净地终止使用此启动的任务

回答 4 投票 0

多线程Python项目中的内存泄漏(?)

我有一个小项目(请记住我只是一个Python初学者)。 该项目由几个较小的 .py 文件组成。首先是 main.py ,如下所示: 来自控制器我...

回答 1 投票 0

celery:守护进程不允许有子进程(使用并发.futures)

在Python(3.6)中,我尝试在celery任务(celery 3.1.17)中创建进程(使用多重处理),但它给出了错误: 守护进程不允许有子进程 代码 def mp(): 与

回答 2 投票 0

是否可以取消`KeyboardInterrupt`上的未决期货?

我正在编写一些代码,这些代码与如下模式并行运行作业: /tmp/test.py 从并发.futures 导入 ProcessPoolExecutor 从多处理导入 freeze_support,

回答 0 投票 0

使用futures.ThreadPoolExecutor异步执行web socket调用时WinError 10014

我正在使用 futures.ThreadPoolExecutor() 异步执行网络套接字调用。 我的函数接收消息列表,通过网络套接字发送它们,等待每个响应并返回...

回答 0 投票 0

Multiprocessing concurrent.futures 不更新全局字典和列表

我需要你的多处理帮助来更新全局字典数据。 我使用了两个函数,第一个函数是在 for 循环中进行多处理。 第二个功能是更新全局字典数据。

回答 1 投票 0

Python 线程池执行器随着时间的推移对于 I/O 绑定任务变慢

我使用线程池执行器在大量端点上运行函数。 我不明白的是它随着时间的推移越来越慢 - 例如最初它在

回答 0 投票 0

如何最好地使用非并发期货?

在我的程序中 对象的创建成本很高, 后来进行了昂贵的修改,并且 最后,对象用于在代码的非常远的区域生成调试输出 我的主要目标是只到

回答 0 投票 0

为什么ProcessPoolExecutor可以使用单进程?

我有在我的 Windows 10 机器和 Linux 服务器上执行的相同 python 代码。 相关部分如下所示: 导入异步 从 concurrent.futures 导入 ProcessPoolExecutor .... 定义

回答 1 投票 0

Python函数中大任务的并行化

我有一个函数,我想在 Python3 中进行多线程/并行化。 calculate(c1,c2) 函数需要很长时间来计算,因此我想将它并行化,以加快计算速度......

回答 1 投票 0

pandas read_csv/excel with concurrent.futures.ProcessPoolExecutor

我的电脑上有一个脚本,可以从网络共享驱动器读取文件(.xlsx、.csv)。由于网络的原因,对读取时间的依赖性很高,它可以从 150 秒开始。到 400 秒。 我是

回答 0 投票 0

使用 concurrent.futures 不返回类覆盖 __getattribute__ 方法

TestClass中的函数使用了一个全局变量data_test。我覆盖了DataTest的特殊方法。我想在run_func中使用concurrent.futures。在这个函数中,我访问了数据中的a1属性...

回答 0 投票 0

挂起线程等待网络请求

我有 24/7 全天候运行的脚本,当 concurrent.futures 中的线程没有对请求做出响应时,有时会卡住。 我使用 concurrent.futures 线程池同时向 Br 发送请求...

回答 1 投票 0

如何使用并发期货计算每个 url 的行数?

我有多个 url,如下所示。 https://website.com/files/123.txt https://website.com/files/456.txt https://website.com/files/789.txt 每个 url 都有如下数据。 第一行 2号线 李...

回答 1 投票 0

ThreadPoolExecutor().map 与 ThreadPoolExecutor().submit 有何不同?

我只是被我写的一些代码弄糊涂了。我惊讶地发现: 以 concurrent.futures.ThreadPoolExecutor(max_workers=4) 作为执行者: results = list(executor.map(f, iter...

回答 4 投票 0

在 Python 中将多个线程的结果收集到列表中的最有效方法是什么?

我需要并行处理一些 IObound 任务,这些任务都会返回结果。 我想知道什么是最有效和最优雅的方法。

回答 0 投票 0

如何将多个参数添加到 concurrent.futures 映射函数?

我正在学习在 python 中使用 concurrent.futures,我想测试的函数有两个参数。我尝试使用“部分”来包含第二个参数,但没有用。怎么...

回答 1 投票 0

PubSub 内存分配通过 Cloud Run 服务激增

我遇到了一个问题,内存分配峰值每天发生 ~3 次。我设置了一个带有端点/webhook 的云运行实例,它获取请求并将它们发布到 pub-...

回答 0 投票 0

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