问题标签 [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.
java - 迭代 Future 对象的映射并调用它们的 get 函数
我很难交互HashMap<String, Future<DPSImporterServiceImpl>>
:
我的地图包含两个条目:{1435748953925=java.util.concurrent.FutureTask@705f23aa, 1435748971395=java.util.concurrent.FutureTask@761ea788}
这是我的记录器结果:
正如您所看到的,地图得到了正确的迭代,因为以开头的日志语句Thread...
是地图中的。该get()
方法虽然不能正常工作,因为它显然是从同一个对象调用的(两次都是从带有 key 的第二个条目1435748971395
)。
这让我很困惑,因为地图肯定不包含相同的对象。
你能告诉我这里可能有什么问题吗?谢谢!
swift - 使用 BrightFutures 控制并行性,这是 Swift 中的“未来”实现
BrightFutures 是 Swift 语言中“未来”的一个很好的实现。 https://github.com/Thomvis/BrightFutures
我喜欢用它来控制多核 CPU 的并行度。有人知道控制要使用的 CPU 内核/物理线程数的方法吗?
scala - 为什么 Future.onSuccess 需要偏函数
我正在尝试使用Future
从一个巧妙的动作返回的 s 将一些基本功能链接在一起,我遇到了一些非常微不足道的绊脚石。
andThen
和onSuccess
方法都需要作为PartialFunction
参数传递。我的理解可能有很大的缺陷,但在阅读了匿名函数之后,似乎andThen
需要知道你的匿名函数以迎合任何Success
或Failure
输入。
鉴于onSuccess
已经只满足这种Success
情况,为什么它仍然需要是一个PartialFunction
?
这段代码表明我遇到的问题:
我得到一个编译错误:
python-3.x - python3中的多处理不起作用
我第一次在 python3 中使用多处理。这是我要实现的:
它抛出错误:
并且每次都出去玩。
python - Python 的 `concurrent.futures` 线程池 - 可以被多个函数调用
我正在寻找一种线程池机制,它将在任何给定时间内限制系统中的线程数。我有几个函数创建了许多线程,我想为此创建相互线程池。
据我了解,一旦将线程列表提供给未来的线程池,它必须首先完成,因为必须使用“with”语句。
期货模块可以做到这一点还是我必须自己写?
python - 多处理队列已满
我正在使用 concurrent.futures 来实现多处理。我收到 queue.Full 错误,这很奇怪,因为我只分配了 10 个作业。
错误:
python - 未执行的未来执行人
在以下代码段中未调用未来:
我的真实代码中有一个真正的 B 级 IPv4 地址,而不是some ip address
. 为什么未来没有被调用?没有引发异常,程序成功退出。
python - Python 期货:如何从 Tornado 中的未来对象获取 json?
这是一个post
处理程序:
处理程序.py
该logic
对象是从 imports.py 中导入的,它是从导入的类中实例化的Logic
进口.py:
逻辑.py
该get_model
方法使用Models
它进行数据库查询并返回未来对象:
模型.py:
这将在控制台中打印一个未来对象:
如何将其转换为 json ?
python - 使用 Concurrent.Futures 模块作为 ThreadPool 调用 Python-get 函数的返回值
我使用 Concurrent.Futures 模块创建了一个 ThreadPool。我创建了线程,一切正常。
但是现在我有一个函数,我想让它与线程并行,问题是我需要每个线程应该运行的函数的返回值,并且不确定在使用期货 threadPool 模块时如何获取它。有办法吗?
android - 如何等到异步方法使用 Futures 完成?
我在 Android 中有一个基于异步改造的 API 调用,需要等待数据库调用,直到 API 调用完成,这样我才能确定正确的数据被输入到数据库中。
我读到您可以使用 Futures 来完成此任务,但是在我当前的实现中,我得到了一个空指针异常。
下面是API方法:
在我继续读取数据库结果之前,我要确保异步代码执行的块在这里。