concurrent.futures 相关问题

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

[以其他方法调用ThreadPoolExecutor时访问类的方法

我有一个方法可以异步检索某些数据,并且必须调用其他方法来存储该数据。我正在使用ThreadPoolExecutor来获取该数据。该类是这样的:A类:...

回答 1 投票 1

为什么并发.futures的submit()不会立即将控制权返回给主程序?

我正在学习current.futures(从线程中移出),但我无法理解提交和等待工作的精确程度。考虑以下代码,启动了两个线程,其中一个...

回答 2 投票 0

如何在并发.futures中获得已分析完成的未来的名称?

[在寻找问题的答案时(链接副本中的一个答案中有一个解决方案),我发现了current.futures,特别是concurrent.futures.as_completed。代码...

回答 1 投票 -1

在并发中使用此功能不起作用

我正在使用current.futures.ProcessPoolExecutor()构造一组数组,以使其更快。但是由于某种原因,该函数在ProcessPoolExecutor()内部无法正常工作。我的代码是...

回答 1 投票 0

Python的多线程/多处理并发功能非常慢

我正在尝试使用多线程和/或多处理来加快我的脚本的速度。本质上,我有一个从CSV读取的10,000个子网的列表,我希望将其转换为IPv4对象,然后...

回答 1 投票 1

Python异步调用单独的函数

我有以下4个函数,其中3个调用外部api来获取随机数据:def get_external_data(zip_code,info_code):data_url = MY_ENDPOINT_1.format(zip_code)data_response = ...

回答 1 投票 0

Pythoncurrent.futures-TypeError:zip参数1必须支持迭代

我想使用多处理功能以1000批处理mongodb文档。但是,下面的代码片段给出了TypeError:zip参数#1必须支持迭代代码:defdocuments_processing(...

回答 1 投票 0

AWS lambda函数实现中的Concurrent.futures

我正在使用AWS Lambda python函数将EBS / RDS快照复制到另一个区域以进行灾难恢复。我遇到的问题是当时有5个快照的副本限制。如果我尝试复制...

回答 1 投票 0

AttributeError的:模块“并发”有没有属性“期货”,当我在Python 3.6尝试并行处理

我试图分裂一个过程,需要很长的时间来使用concurrent.futures模块多个进程。附件是以下主要功能代码:与concurrent.futures.ProcessPoolExecutor()为...

回答 1 投票 1

多处理与Concurrent.futures库python(不适用于Google Compute Engine)

我正在尝试并行化一个pandas操作,该操作将具有逗号分隔值的数据帧列拆分为2列。正常的pandas操作在我的python实例上大约需要5秒...

回答 1 投票 0

如何跨Dask分布式工作器共享大型只读对象

问题我试图通过apply()发送一个2GB的CPython只读对象(可以被pickle)来分配给分布式工作者。这最终会为进程/线程(14+ GB)消耗大量内存。是......

回答 1 投票 0

将SIGTERM发送到正在运行的任务,dask已分发

当我提交一个小的Tensorflow培训作为单个任务时,它会启动其他线程。当我按下Ctrl + C并引发KeyboardInterrupt时,我的任务被关闭但底层线程没有被清理......

回答 1 投票 0

concurrent.futures.ThreadPoolExecutor不会打印错误

我试图使用concurrent.futures.ThreadPoolExecutor模块并行运行一个类方法,我的代码的简化版本几乎是以下:类TestClass:def __init __(...

回答 1 投票 1

在python多处理中从bash调用另一个应用程序非常慢

我正在尝试使用qark分析器来分析使用python进行多处理的一组apks。试图分析一组100个apks我发现我写的自动化分析的应用程序是......

回答 1 投票 2

从Python将数据插入Postgresql

每100万行≈105秒插入Postgresql本地数据库的表上有2个索引和4列它是慢还是快? Python代码:从并发导入os导入pandas为pd ....

回答 1 投票 0

concurrent.futures.Executor.map中的异常处理

来自https://docs.python.org/3/library/concurrent.futures.html#concurrent.futures.Executor.map如果func调用引发异常,则在检索其值时将引发该异常...

回答 3 投票 2

`concurrent.futures.map`是线程安全的吗?

我发现doc没有提到它:https://docs.python.org/3/library/concurrent.futures.html#concurrent.futures.Executor.map

回答 1 投票 0

在Python中使用Pebble重新启动/重建超时过程?

我使用并发期货使用API 从远程服务器下载报告。为了通知我报告已正确下载,我只需要打印出ID的功能。我有一个问题......

回答 1 投票 0

将来等待后引发TypeError

我正在尝试使用并行处理在一些现有代码中优化昂贵的操作。我过去曾使用concurrent.futures这样做,但只有当他们没有返回任何内容时才这样做。这次 ...

回答 1 投票 4

锁定多线程pywinauto发送键

我是pywinauto的新手,我正在创建几个记事本窗口并在所有窗口中键入文本。但是,这并不依赖于彼此,因此可以使用线程同时运行。但是,......

回答 2 投票 0

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