它工作得很好，但是线程数一直在增加。executorService = Executors.newFixedThreadPool(marketplaces.size());
List<CompletableFuture<List<OrderResponseDto>>> futures = marketplaces.stream().map(
m -> CompletableFuture.supp
浏览 38提问于2018-09-05得票数 0
回答已采纳
我有如下使用CompletableFuture的方法： CompletableFuture.supplyAsync(() -> someMethodThatReturnsA()); Comple
浏览 0提问于2018-04-30得票数 2
我有一个线程，在它内部进行数据库调用，有时会挂起，通常超时应该在客户端库中处理，但在这种情况下，客户端库不能正确处理它，所以我必须添加额外的计划作业来取消正在进行db调用的线程，如果它需要太长的时间来避免背压handler.cancel(true);}, 3, TimeUnit.SECONDS);
有没有合适的方法在没有TimeUnit.MILLISECONDS.sleep(1);的情况下中断线程
浏览 0提问于2019-05-25得票数 0
我认为新的java8 CompletableFuture将能够使用"thenComposeAsync“方法一个接一个地执行异步任务，而不会阻塞线程。如果nThreads <= 2，下面这段代码永远不会执行“Task3”：int nThreads= 2;
Executor e= Executors.newFixedThread
浏览 1提问于2014-04-14得票数 3
1回答
因此，我创建了一个单独的CompletableFuture，如：CompletableFuture<List<DTO2> future2 = CompletableFuture.supplyAsync(我是Java8并发特性(如CompletableFutu
浏览 4提问于2022-01-07得票数 2
CompletableFuture retrunsVal = CompletableFuture.supplyAsync(() -> { return newObject(); //some logic});
根据我目前的理解，如果我不调用retrunsVal.join();，
浏览 12提问于2021-03-22得票数 0
2回答
问题是，当我调用API访问类时，它必须是异步的(由android定义)，所以我使用了一个新的线程，但是当API access类返回好的结果时，使用数据的类中的返回值为null。我已经尝试用thread.join()连接这两个线程，但是它不起作用。
浏览 0提问于2019-04-29得票数 0
回答已采纳
的文档显示它是线程安全的。我知道它本身是线程安全的。但是，如果我在这样的线程中共享它，会不会是线程安全呢？boolean run = true;
activity = LocalTime.now();
浏览 1提问于2020-11-08得票数 0
回答已采纳
3回答
获得完全未来的结果
、、、、
在springboot应用程序中，我使用从异步线程返回的completablefuture。我的执行情况如下。根据我的理解，应该为列表中的每一项启动一个新线程，并且应该并行处理。ServiceA.javaServiceB serviceb;
List<CompletableFuture> list = new ArrayList<>();
List&l
浏览 6提问于2020-03-10得票数 1
回答已采纳
库有一个内部线程池，用于执行异步方法的计算工作。我想确保满足以下两项要求：
我的异步方法的所有计算都由内部线程池执行，而不是由用户线程(即方法调用方的线程)执行。CompletableFuture<Data> requestAsync(Address addre
浏览 1提问于2019-09-24得票数 3
在下面的代码中，意图是实现任务的异步执行，只要它在100 ms以内运行，否则会引发来自其他线程的超时异常， public static <T> CompletableFuture<T> failAfter(long longValu
浏览 1提问于2018-07-27得票数 0
连接在线程中，是最后一个命令，没有副作用。那么在这种情况下线程仍然是活动的吗？- 问题是因为这样的事情？()
一些相关的问题:什么时候线程执行者发出信号来释放一个新的任务？我想，当CompletableFuture进入下一个链式CompletableFuture？所以我只能进行内存泄漏而不是线程泄漏？因此，在completes B之外的人
浏览 18提问于2021-11-19得票数 0
回答已采纳
2回答
我有一个检查CompletableFuture执行时间的方法。如果这样的CompletableFuture执行超过2秒，我想终止这个任务。但是，如果我没有对执行CompletableFuture方法的所有线程进行控制，我怎么做呢？final CompletableFuture<List<List<Student>>> responseFuture = new CompletableFuture<>();
responseFuture.sup
浏览 3提问于2017-12-02得票数 2
1回答
我正在测试CompletableFuture是如何工作的。我对如何并行执行任务感兴趣： CompletableFuture one = CompletableFuture.runAsync(() -> { });
CompletableFuture two = CompletableFuture.runAsync(()
浏览 0提问于2019-03-23得票数 2
回答已采纳
我希望将一个Runnable封装在要异步计算的CompletableFuture中，但要控制计算什么时候开始和结束。(1); try {
countDownLatch.await(CompletableFuture.java:1771) at java.util.concurrent.CompletableFuture</e
浏览 4提问于2019-09-19得票数 3
回答已采纳
基本上，get()似乎做了我所期望的事情(它阻止当前线程直到所有的未来完成)，而orTimeout()的行为似乎非常奇怪(在第一个未来完成之后，它会尽快解除当前线程的阻塞)。<Void> getAllOfFuture() { CompletableFuture.runAsync(() -> sleep(1)),
CompletableFuture.runAsyn
浏览 4提问于2020-11-12得票数 4
对于可完成的期货，我是新手，我试图了解在CompletableFuture上注册的回调线程是在哪个线程上使用构造函数(())构造的。例如： CompletableFuture.supplyAsync(() -> {
//..()中的转换是注册的，它将在任务完成后在与任务相同的线程中立即执行。CompletableFuture
浏览 0提问于2019-05-29得票数 1
回答已采纳
1回答
, HttpServletRequest request) { CompletableFuture.supplyAsync我想要实现的是，当UI发送请求时，它应该继续接收一条消息，上面写着仍在加载，这样请求就不会超时吗？
浏览 0提问于2018-04-09得票数 1
回答已采纳
我有：Map<String, CompletableFuture<Response>>我希望结果完成后，每一个
浏览 0提问于2019-06-19得票数 1
2回答
我正在学习关于java 8 CompletableFuture的知识，并最终得到了这个。CompletableFuture<ServiceAResponse> serviceAFuture = CompletableFuture.supplyAsync(
() -> this.ServiceA.retrieve(serviceARequest), serviceAExec
浏览 127提问于2017-01-26得票数 19
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
