问题标签 [concurrent.futures]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
1 回答
3195 浏览

java - 迭代 Future 对象的映射并调用它们的 get 函数

我很难交互HashMap<String, Future<DPSImporterServiceImpl>>

我的地图包含两个条目:{1435748953925=java.util.concurrent.FutureTask@705f23aa, 1435748971395=java.util.concurrent.FutureTask@761ea788}

这是我的记录器结果:

正如您所看到的,地图得到了正确的迭代,因为以开头的日志语句Thread...是地图中的。该get()方法虽然不能正常工作,因为它显然是从同一个对象调用的(两次都是从带有 key 的第二个条目1435748971395)。

这让我很困惑,因为地图肯定不包含相同的对象。

你能告诉我这里可能有什么问题吗?谢谢!

0 投票
1 回答
415 浏览

swift - 使用 BrightFutures 控制并行性,这是 Swift 中的“未来”实现

BrightFutures 是 Swift 语言中“未来”的一个很好的实现。 https://github.com/Thomvis/BrightFutures

我喜欢用它来控制多核 CPU 的并行度。有人知道控制要使用的 CPU 内核/物理线程数的方法吗?

0 投票
2 回答
2096 浏览

scala - 为什么 Future.onSuccess 需要偏函数

我正在尝试使用Future从一个巧妙的动作返回的 s 将一些基本功能链接在一起,我遇到了一些非常微不足道的绊脚石。

andThenonSuccess方法都需要作为PartialFunction参数传递。我的理解可能有很大的缺陷,但在阅读了匿名函数之后,似乎andThen需要知道你的匿名函数以迎合任何SuccessFailure输入。

鉴于onSuccess已经只满足这种Success情况,为什么它仍然需要是一个PartialFunction

这段代码表明我遇到的问题:

我得到一个编译错误:

0 投票
1 回答
1137 浏览

python-3.x - python3中的多处理不起作用

我第一次在 python3 中使用多处理。这是我要实现的:

它抛出错误:

并且每次都出去玩。

0 投票
0 回答
104 浏览

python - Python 的 `concurrent.futures` 线程池 - 可以被多个函数调用

我正在寻找一种线程池机制,它将在任何给定时间内限制系统中的线程数。我有几个函数创建了许多线程,我想为此创建相互线程池。

据我了解,一旦将线程列表提供给未来的线程池,它必须首先完成,因为必须使用“with”语句。

期货模块可以做到这一点还是我必须自己写?

0 投票
2 回答
11361 浏览

python - 多处理队列已满

我正在使用 concurrent.futures 来实现多处理。我收到 queue.Full 错误,这很奇怪,因为我只分配了 10 个作业。

错误:

0 投票
1 回答
57 浏览

python - 未执行的未来执行人

在以下代码段中未调用未​​来:

我的真实代码中有一个真正的 B 级 IPv4 地址,而不是some ip address. 为什么未来没有被调用?没有引发异常,程序成功退出。

0 投票
1 回答
4135 浏览

python - Python 期货:如何从 Tornado 中的未来对象获取 json?

这是一个post处理程序:

处理程序.py

logic对象是从 imports.py 中导入的,它是从导入的类中实例化的Logic

进口.py:

逻辑.py

get_model方法使用Models它进行数据库查询并返回未来对象:

模型.py

这将在控制台中打印一个未来对象:

如何将其转换为 json ?

0 投票
1 回答
6178 浏览

python - 使用 Concurrent.Futures 模块作为 ThreadPool 调用 Python-get 函数的返回值

我使用 Concurrent.Futures 模块创建了一个 ThreadPool。我创建了线程,一切正常。

但是现在我有一个函数,我想让它与线程并行,问题是我需要每个线程应该运行的函数的返回值,并且不确定在使用期货 threadPool 模块时如何获取它。有办法吗?

0 投票
2 回答
1156 浏览

android - 如何等到异步方法使用 Futures 完成?

我在 Android 中有一个基于异步改造的 API 调用,需要等待数据库调用,直到 API 调用完成,这样我才能确定正确的数据被输入到数据库中。

我读到您可以使用 Futures 来完成此任务,但是在我当前的实现中,我得到了一个空指针异常。

下面是API方法:

在我继续读取数据库结果之前,我要确保异步代码执行的块在这里。