concurrent.futures 相关问题

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

如何在执行程序中停止循环运行?

我正在运行需要时间才能完成的功能。用户可以选择停止此功能/事件。是否有一种简单的方法来停止线程或循环? class ThreadsGenerator:MAX_WORKERS = 5 ...

回答 1 投票 0

如果出现错误,如何在ThreadPoolExecutor中重新执行函数?

我正在从python的concurrent.futures文档中尝试python的ThreadPoolExecutor的这个示例代码。具体导入concurrent.futures导入urllib.request URLS = ['http://www.foxnews ....

回答 1 投票 0

从concurrent.futures使用ThreadPoolExecutor时的max_workers数量?

在从Parallel.futures决定在ThreadPoolExecutor中设置max_workers的内容时要考虑哪些因素?只要你能期望Python 3.5+可用,有什么理由不......

回答 1 投票 7

何时不使用asyncio有意义?

在什么情况下,一个线程或执行器(使用线程)通过asyncio?随着我使用Python(CPython)的经验取得了进展,它集中在工作中优化脚本以做某种形式......

回答 1 投票 1

使用ProcessPoolExecutor进行Web Scraping:如何将数据恢复到队列和结果?

我编写了一个程序来抓取一个网站并抓取某些数据。我想通过使用ProcessingPoolExecutor加快执行速度。但是,我无法理解我怎么能......

回答 1 投票 1

for循环不能在并行代码中异步执行

我有以下函数:使用ProcessPoolExecutor(max_workers = None)作为执行函数:期货= fetch_row()中的行的[executor.submit(执行,行)]以供将来使用...

回答 1 投票 2

是否可以在进程之间传递Python Future对象?

根据我的实验,我猜这个答案是否定的。但也许有可能对期货模块进行一些改变。我想提交一个自己创造的工人......

回答 1 投票 10

将tqdm与concurrent.futures一起使用?

我有一个多线程函数,我想要一个使用tqdm的状态栏。有没有一种简单的方法来显示ThreadPoolExecutor的状态栏?并行化部分令我感到困惑。 ...

回答 1 投票 8

Java CompletableFuture分配执行程序

我对在CompletableFuture中定义执行程序感到困惑。我不知道如何告诉CompletableFuture在该特定执行程序中运行它。提前致谢。 //假设我有一个执行者......

回答 2 投票 1

为什么concurrent.futures在返回np.memmap时会占用内存?

问题我的应用程序是在内存中提取zip文件列表并将数据写入临时文件。然后我将内存映射到临时文件中的数据,以便在另一个函数中使用。当我做 ...

回答 1 投票 2

存储结果ThreadPoolExecutor

我对“concurrent.futures”并行处理相当新,我正在测试一些简单的实验。我写的代码似乎有效,但我不确定如何存储结果。我有 ...

回答 1 投票 1

Python Processpoolexecutor - 杀死队列?

这是我在stackoverflow上的第一个问题。我几乎能够在这里找到我需要知道的东西。非常感谢这个顺便说一下。然而。如果我试图杀死我的ProcessPoolExecutor它将只通过...

回答 2 投票 1

Klein应用程序延期

我正在探索克莱因和延期。在下面的示例中,我尝试使用子进程递增数字并通过Future返回它。我能够收到未来的回电。问题是 ...

回答 1 投票 0

在一个dask包上依次迭代

我需要将一个非常大的dask.bag的元素提交给一个非线程安全的商店,即我需要像dbag中的x一样的东西:store.add(x)我不能使用计算,因为包大到适合...

回答 1 投票 1

将multiprocessing.Process与concurrent.future._base.Future集成

我需要创建子进程,使用Future接收结果,然后在需要时杀死其中一些。为此,我已经子类化了multiprocessing.Process类并返回一个Future ...

回答 1 投票 0

scala.concurrent.Future [play.api.mvc.Result] required:play.api.mvc.Result

我想要一个Action.async,(1)尝试从数据库中获取值。如果数据库不可用,它将尝试连接到另一个资源,并(2)从那里获取值。因为这两个资源......

回答 2 投票 0

Python 3 concurrent.futures套接字服务器与ThreadPoolExecutor一起使用,但不与ProcessPoolExecutor一起使用

我试图使用新的concurrent.futures类创建一个简单的套接字服务器。我可以使用ThreadPoolExecutor使其正常工作,但它只是在我使用ProcessPoolExecutor时挂起而我不能......

回答 2 投票 0

多线程:URL提取

我试图多处理一个URL获取过程,因为它会花费大量的时间来处理我想要处理的300k网址。不知何故,我的代码在随机数量后停止工作......

回答 1 投票 0

concurrent.futures.as_completed如何工作?

我正在学习python并发性,并且我介绍了期货的概念。我读到as_completed()接受一个可迭代的期货,并在完成后产生它们。我想知道它是怎么回事......

回答 1 投票 8

并发期货网络抓取

谁在读他的!感谢您抽出宝贵时间来看看这个。我目前正在尝试开发一个快速的webscraping函数,所以我可以刮掉一大堆文件。这是我的代码......

回答 1 投票 0

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