completable-future 相关问题

在Java 8中,可以显式完成的Future(设置其值和状态),并且可以包括在完成时触发的依赖函数和动作。

在CompletableFuture上同步使用acceptEither进行任务调度

我正在通过CompletableFuture API学习并发性。假设我有两项任务:一项耗时250毫秒,另一项耗时2500毫秒。在以下代码中:Supplier > ...

回答 1 投票 1

CompletableFuture链接

我正在寻找有关链接多个CompletableFutures方法的建议。假设我需要执行3次操作。搜索表单主表(如果主表中不存在数据,则插入...

回答 1 投票 0

为什么CompletableFuture中的断点也停止在主线程中执行?

我正在尝试一个简单的代码片段,以检查CompletableFuture是否确实在单独的线程中工作。类Scratch {public static void main(String [] args){CompletableFuture.runAsync(()-> ...

回答 1 投票 0

正在测试CompletableFuture.allOf。加入需要永远

我正在尝试测试使用CompletableFuture.allOf的方法。我模拟期货,以便它们在加入时返回所需的价值。由于某些我无法理解的原因。结果的join()需要...

回答 1 投票 0


正确覆盖CompletableFuture.cancel

我注意到,如果将来调用thenApply,则覆盖cancel方法无效。派生的未来不知道原始文档具有此类替代。代码...

回答 2 投票 3

调用列表 具有超时并收集结果

我正在尝试以每个工作者2秒钟的超时来停止许多Worker实例,我希望其中一些实例会失败。我想实现以下目标,但我知道这是不好的方法。我不能使用...

回答 2 投票 1

如何在Java中执行非阻塞HTTP调用?

我有一个第三方API,我使用HTTP GET请求进行调用。每个请求都需要几秒钟才能得到响应。目前,我正在使用正在...上执行的CompletableFuture ...

回答 1 投票 1

为什么我的Thread.sleep进入CompletableFuture时会结束我的进程?

我正在尝试创建CompleteableFuture。我只是想注销一些声明。这是我的代码:static CompletableFuture createFuture(String name){return ...

回答 1 投票 0

是否有可能在创建它的同一线程中运行可完成的未来?

想知道一个completablefuture是否可以在创建它的线程中运行。您可能会问为什么我需要这样做,因为completablefuture用于异步编程。原因是...

回答 1 投票 1

我如何模拟可完成的Future的supplyAsync方法响应?

public class Test {public Obj func(){CompletableFuture completableFuture = CompletableFuture.supplyAsync(new ContextSupplier {public Obj onGet(){...

回答 1 投票 0

带有确认的海王星下降顶点属性

我曾尝试通过Gremlin Tinkerpop查询来查询Amazon neptune,以删除Vertex的属性。它工作正常,但是在删除属性时无法得到TRUE / FALSE的确认。但是,我可以管理...

回答 1 投票 0

关于使用CompletableFuture的建议

我希望使用CompletableFuture进行一些推荐。如果我有一个整数列表,则对于每个整数,我想执行3个动作,这需要一些时间。例如,乘法,除法和...

回答 2 投票 0

使用CompletableFuture的最佳实践

我想知道使用CompletableFuture的最佳实践。如果我有一个整数列表,则对于每个整数,我想执行3个动作,这需要一些时间。例如,乘以...

回答 2 投票 0

带有Future和completableFuture的中断读取方法

在解决任务时,我注意到无法解释的行为。我的任务是从InputStream读取并在超时后中断该读取。即使很多人说阻止读取也可以...

回答 1 投票 0

[启用Java安全管理器后,获取系统属性“ os.arch”时权限被拒绝期望

我有一个简单的Java应用程序ClientApp,它启用了Java安全管理器。该应用程序正在尝试调用获取“ os.arch”系统属性的Test jar方法。由于现在是时候...

回答 1 投票 0

CompletableFuture.runAsync与CompletableFuture数组

我在一个项目中找到此代码:int threadCount = 10; CompletableFuture> []期货=新的CompletableFuture> [threadCount]; for(int i = 0; i

回答 1 投票 0

futures.forEach(CompletableFuture :: join)并行运行所有任务?

我有多个可完成的期货创建为:CompletableFuture future1 = CompletableFuture.runAsync(()-> xxx); CompletableFuture future2 = CompletableFuture.runAsync(()...

回答 1 投票 0

Completable Future-使用Completable Future,我正在尝试从两个不同文件中获取数据

我试图从两个不同的文件中读取数据,一个是csv格式,另一个文件是xml数据。使用completeFuture,我试图从两个异步文件中读取数据。我正在获取...

回答 2 投票 0

如何知道春季启动@async并使用@scheduled完成所有线程

我需要使用异步调用REST API(一次调用50个)。每个呼叫都需要一些时间(20秒)来响应,然后进行一些处理。然后需要知道所有线程何时完成,...

回答 1 投票 0

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