concurrent.futures 相关问题

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

如何使用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

如何从输入流中读取一段时间?

我必须在特定时间从InputStream 读取行并返回我在列表中读取的行。在我当前的解决方案中,我不确定这是否是中断线程的最佳方法,因为有些......

回答 1 投票 0

Streamlit:线程“ThreadPoolExecutor-8_0”:缺少 ScriptRunContext

我正在尝试使用 python concurrent.futures.ThreadPoolExecutor() 为给定的元数据运行“摄取”函数的多个实例。 “final”是保存参数值的元组列表...

回答 1 投票 0

Lambda函数在批量执行后不执行,但没有显示任何错误

我有一个将 .xlslx 文件行插入 DDB 的函数。一切都工作正常,只要有 15 分钟的超时时间和 128MB 内存,我就可以完美地完成任务。现在对于一个非常具体的文件我有 160K ...

回答 1 投票 0

我可以退出“as_completed”池执行器循环(取消所有剩余任务)吗?

其想法是运行一组任务,在完成后处理它们,一旦返回所需的结果,就取消剩余的任务。我不介意等待已经开始完成的任务,...

回答 1 投票 0

如何创建一个 Python 并发 Future,在 Future 列表完成时发出信号?

我有一个函数,可以向 ThreadPoolExecutor 提交多个任务,并返回每次提交创建的 Future 列表: def Submit_tasks() -> [未来]: 期货=[] 对于我在范围内...

回答 2 投票 0

多进程 Pandas Group 在进程启动后无法执行任何操作

我有一个相当大的 pandas 数据框,大约有 600,000 行 x 50 列。我想执行 groupby.agg(custom_function) 来获取结果数据。 custom_function 是一个函数...

回答 1 投票 0

使用了Concurrent.futures,但只有一个核心处于活动状态

我想了解并发。未来所以我想创建一个小代码示例。 从 1 到 $10^7$ 的数字应相加。我想用4核。所以我创建了4个列表,即 [1,5,9,...

回答 2 投票 0

ThreadPoolExecutor 在队列为空之前退出

我的目标是同时从队列中抓取 URL。根据抓取结果,队列可能会被扩展。这是 MWE: 导入队列 从并发.futures 导入 ThreadPoolExecutor 进口...

回答 1 投票 0

如何将常量值(列表)传递给concurrent.futures.Executor.map?

相关问题无法回答我的确切用例: 将多个参数传递给concurrent.futures.Executor.map? 我有一个需要 2 个参数的函数。第二个参数是一个列表,并且在 m...

回答 1 投票 0

使用 ThreadPoolExecutor 填充列表和字典

如何使用ThreadPoolExecutor填充字典和列表? 函数返回空字典和列表。 由于 Windows 问题,我无法使用多处理来执行此任务。 看起来 Manager() 的工作原理不一样...

回答 1 投票 0

Python3中使用concurrent.futures线程池识别线程运行函数

我有以下代码: 导入并发期货 def f(a, b): print("线程 x => "+a+" "+b) 以并发.futures.ThreadPoolExecutor(max_workers=3) 作为执行器: ...

回答 1 投票 0

将全局变量与并发使用。futures

通过以下并发.futures.ProcessPoolExecutor 程序,我试图使工作进程能够在全局范围内修改 var 字典。然后我希望能够使用那个mo...

回答 1 投票 0

生成器执行期间普通Python方法和生成器之间的交错

是否可以使用concurrent.futures中的ThreadPoolExecutor从生成器执行交错到正常方法执行。 导入并发期货 从应用程序导入执行器 def 生成器...

回答 1 投票 0

在Python中的每个线程中建立多个套接字连接,在3个连接后卡住?

我有一个包含用户名/主机信息的对象字典,用于连接到服务器,并希望每个连接在它自己的线程中运行,但似乎从我的 100 个测试对象中最多获得 3 个

回答 1 投票 0

使用Python多线程将报废的信息附加到列表中,导致0个列表

我正在使用具有并发 future 线程的 Selenium 无头浏览器,以便从网站抓取信息并将其输出到 Excel 工作表。然而,虽然美丽汤能够找到...

回答 1 投票 0

在 Python 中完成另一个 Future 后终止一个 Future

我目前正在使用 Python 中的并发.futures 和 uiautomator2 库来自动化 Android 设备上 WhatsApp 的 UI 交互。在我的场景中,我想自动化

回答 1 投票 0

concurrent.futures.ProcessPoolExecutor() python 中的共享变量

我想使用python中的concurrent.futures模块并行更新全局变量 事实证明,使用 ThreadPoolExecutor 可以更新我的全局变量,但是 CPU 没有使用它们的全部

回答 2 投票 0

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