根据某些条件停止/完成循环的CompletableFuture
CompletableFuture是Java 8引入的一个类，用于支持异步编程和处理异步任务的结果。它是一个可以用于处理异步操作结果的容器，可以通过编程方式将多个异步任务组合在一起，以便在任务完成时执行特定的操作。
CompletableFuture可以根据某些条件停止或完成循环。以下是一个完善且全面的答案：
概念： CompletableFuture是Java中的一个类，用于支持异步编程和处理异步任务的结果。它提供了一种简单而强大的方式来处理异步操作的结果。
分类： CompletableFuture可以分为两类：有返回值的CompletableFuture和无返回值的CompletableFuture。有返回值的CompletableFuture可以通过调用get()方法获取异步任务的结果，而无返回值的CompletableFuture则用于执行一些不需要返回结果的异步任务。
优势：
- 异步编程：CompletableFuture提供了一种简单而强大的方式来处理异步操作的结果。它可以帮助开发人员更容易地编写异步代码，提高代码的可读性和可维护性。
- 组合操作：CompletableFuture可以通过编程方式将多个异步任务组合在一起，以便在任务完成时执行特定的操作。这种组合操作可以帮助开发人员更好地管理异步任务之间的依赖关系。
- 异常处理：CompletableFuture提供了一种简单而灵活的方式来处理异步任务中的异常。开发人员可以通过调用exceptionally()方法来处理异常情况，并返回一个默认值或执行其他操作。
- 可扩展性：CompletableFuture可以与其他Java库和框架无缝集成，例如Spring和Hibernate。这使得它成为开发大型应用程序的理想选择。
应用场景： CompletableFuture在以下场景中非常有用：
- 并行处理：CompletableFuture可以将多个异步任务并行执行，并在所有任务完成时执行特定的操作。这对于提高应用程序的性能和响应能力非常有帮助。
- 异步调用：CompletableFuture可以用于执行异步调用，并在调用完成时执行特定的操作。这对于处理网络请求、数据库查询等耗时操作非常有用。
- 任务依赖：CompletableFuture可以通过编程方式将多个异步任务组合在一起，并在所有任务完成时执行特定的操作。这对于处理任务之间的依赖关系非常有帮助。
推荐的腾讯云相关产品和产品介绍链接地址： 腾讯云提供了一系列与云计算相关的产品，以下是一些推荐的产品和其介绍链接地址：
- 云服务器（CVM）：腾讯云的云服务器产品，提供高性能、可靠的云服务器实例，适用于各种应用场景。详细介绍请参考：https://cloud.tencent.com/product/cvm
- 云数据库MySQL版（CDB）：腾讯云的云数据库产品，提供稳定可靠的MySQL数据库服务，支持高可用、备份恢复等功能。详细介绍请参考：https://cloud.tencent.com/product/cdb
- 云函数（SCF）：腾讯云的无服务器函数计算产品，提供按需运行代码的能力，无需管理服务器。详细介绍请参考：https://cloud.tencent.com/product/scf
- 人工智能平台（AI Lab）：腾讯云的人工智能平台，提供丰富的人工智能服务和工具，包括图像识别、语音识别、自然语言处理等。详细介绍请参考：https://cloud.tencent.com/product/ailab
请注意，以上推荐的产品和链接仅供参考，具体选择应根据实际需求和情况进行。
相关·内容
1回答
我有无限的承诺队列(可完成的未来)作为输入。目标是一个接一个地运行承诺，直到结果满足条件，停止对当前承诺的处理和返回结果。
我的迭代解决方案如下所示：
volatile boolean shouldKeepReading = true;
....
CompletableFuture<Integer> result = promisesQueue.poll().get();
while (shouldKeepReading) {
result = result.thenCompose(res -> {
if (conditionPass(res))
浏览 6提问于2021-12-07得票数 4
回答已采纳
我有以下代码：
return CompletableFuture.supplyAsync(() -> {
return foo; // some custom object
})
.thenAccept(foo -> {
// ??? need to spawn N async parallel jobs that works on 'foo'
});
第一个任务异步创建foo对象，然后我需要在它上运行N个并行进程。
那么，是否有更好的方法来做到这一点：
...
CompletableFuture[] parallel = new Completa
浏览 4提问于2016-06-15得票数 3
回答已采纳
我正在尝试用mockito测试CompletableFuture.supplyAsync函数，但是测试还没有完成，可能是因为可完成的未来没有返回。我不知道我在代码中遗漏了什么。有人能帮忙吗。
我写的代码如下。因此，有返回用户的UserService类，返回用户实体的UserEntityService类，以及检查实体是否属于用户的验证类。
我想测试所传递的实体是否属于用户。
class UserService {
CompletableFuture<User> getUser(String userName) {
log.info("Fetching
浏览 27提问于2022-08-12得票数 0
回答已采纳
因此，我有一个用例，其中我有四个任务A，B，C，D，我想并行运行。这些任务的响应类型是布尔型。
在并行运行它们之后，我希望在以下任一条件下停止执行
在从任何一个任务接收第一个false时返回。所有4个任务都已完成，没有一个任务返回false。
我的项目是使用Java，springboot
所以我试图利用可完成的未来来实现这一目标。我可以通过下面的代码在第一步取得成功。但不是第二步。有什么帮助吗？
import java.util.Arrays;
import java.util.List;
import java.util.concurrent.CompletableFuture;
impor
浏览 3提问于2021-06-09得票数 0
3回答
我有一组元素，并对每个元素执行method，将其作为Runnable传递给CompletableFuture.runAsync()。在执行过程中，可能需要停止整个计算，所以我在执行方法之前检查了一些条件。如果计算应该停止，那么我抛出一个异常，该异常在CompletableFuture外部处理。我想阻止所有Runnables的执行，这些Runnables是在抛出异常之后执行的。因此，换句话说，我不想等待所有的CompletableFutures完成，当它们中的任何一个抛出异常时。 Set elements = ...
Executor executor = Executors.newFixed
浏览 20提问于2019-09-11得票数 2
回答已采纳
2回答
我希望下面的代码总是打印"Errored"，但有时它会打印"outerinner“。我想要的是“外部”完成，“内部”使用“外部”结果产生自己的结果，如果未来失败，我做错了什么？
CompletableFuture<String> outer = CompletableFuture.supplyAsync(() -> "outer");
CompletableFuture<String> inner = CompletableFuture.supplyAsync(() -> "in
浏览 5提问于2020-10-20得票数 3
回答已采纳
为了不阻塞执行，我需要动态地组合CompletionStages (基于计算结果)，并且最终我需要捕获操作期间可能出现的异常，以便小心地关闭执行。
我已经实现了类似如下的东西：
public CompletableFuture<Data> getData() {
final Data accumulator = new Data();
CompletableFuture<Data> result = new CompletableFuture<>();
CompletableStage exec = ... //starting
浏览 8提问于2020-05-13得票数 0
回答已采纳
CompletableFuture<String> future = CompletableFuture.completedFuture(null);
for(int _retrial = 1 ; _retrial <= getRetrialCountBasedOnSomeLogic() ; _retrial++) {
int finalRetrial = _retrial;
future = future
.thenCompose(lastRetrialStatus -> {
if(Strings.isNullOrEmpty(las
浏览 23提问于2019-11-21得票数 1
回答已采纳
我正在查询Dynamo DB以获得给定的主键。主键由两个UUID字段(fieldUUID1，fieldUUID2)组成。对于上面的主键和值列表的组合，我有很多查询要执行。为此，我使用带有ExecutorService的异步CompleteableFuture，线程池大小为4。
在所有查询返回结果(即CompletableFuture<Object> )后，我使用可完成未来的allOf方法连接它们，该方法确保所有查询执行都已完成，并提供CompletableFuture<void>，在该方法上，我使用流接收CompletableFuture<List<Obje
浏览 0提问于2019-09-04得票数 0
我希望等待多个事件，并决定尝试用CompletableFuture实现这一点。
CompletableFuture a1 = new CompletableFuture();
CompletableFuture a2 = new CompletableFuture();
CompletableFuture a3 = new CompletableFuture();
CompletableFuture b = new CompletableFuture();
CompletableFuture subFuturesA= CompletableFuture.allOf(a1, a2, a3);
C
浏览 13提问于2022-07-14得票数 1
回答已采纳
我有个问题。我有4个类：classA、classB、classC，它们都有一个叫做run()的函数。现在我正在尝试使用异步，所以我想要的是以下内容：
在我的run()At中，我从classA调用一个异步函数，称为classA.run()的结束，我称它为classA.run()的结束，我想等到classA和classB在运行classC.run().之前打印出它们的行
这是每个类的代码。A类：
public class classA {
public void run() {
System.out.println("CLASS A");
浏览 4提问于2021-05-02得票数 0
回答已采纳
2回答
中出现异常时，中断所有线程。
、、、、
我有一个方法名someTask，我必须调用它100次，并且我正在使用如下所示的异步编码。
for (int i = 0; i < 100; i++) {
futures.add(CompletableFuture.supplyAsync(
() -> { someTask(); },
myexecutor
));
}
如果在执行someTask()时在任何线程上发生异常，我希望中断所有当前线程，并停止未来线程的执行。处理这件事最好的方法是什么？
更新：我正在使用。
浏览 0提问于2020-06-29得票数 2
1回答
在spring boot应用程序中使用CompletableFuture时，我注意到在使用CompletableFuture异步运行的函数中发生了异常，但没有任何日志。函数执行停止，因此CompletableFuture已完成。为什么日志里什么都没有？当我在.runAsync中使用.whenComplete时，我能够记录错误。
void function() {
CompletableFuture
.runAsync(() -> runAsyncfunction())
.whenComplete((result, err) -> {//log the er
浏览 4提问于2021-11-04得票数 1
我想调用CompletableFuture.supplyAsync()将阻塞任务委托给另一个线程。一旦任务完成，我希望CompletableFuture.thenAccept使用者能够在调用线程的上下文中运行。
例如：
// Thread 1
CompletableFuture.supplyAsync(() -> {
// Thread 2
return BlockingMethod();
}).thenAccept((
Object r) -> {
// Thread 1
});
下面的代码表明CompletableFuture.thenAccept
浏览 10提问于2016-04-29得票数 4
回答已采纳
我想知道allOf方法CompletableFuture是否会轮询或进入等待状态，直到所有CompletableFutures传递给该方法完成它们的执行。我查看了allOf方法在IntelliJ中的代码，它正在执行某种二进制搜索。
请帮助我了解CompletableFuture的CompletableFuture方法实际上是做什么的。
public static CompletableFuture<Void> allOf(CompletableFuture<?>... cfs) {
return andTree(cfs, 0, cfs.length - 1);
浏览 0提问于2019-08-06得票数 9
回答已采纳
通常，在使用CompletableFuture时，我会调用thenApply或其他方法，以便在结果可用时立即执行某些操作。然而，我现在有一种情况，我想处理结果，直到我收到一个积极的结果，然后忽略所有进一步的结果。
如果我只想获得第一个可用的结果，我可以使用CompletableFuture.anyOf (尽管我不喜欢仅仅为了调用anyOf就必须将列表转换为数组)。但这不是我想要的。我想要第一个结果，如果它没有一个理想的结果，那么我想处理第二个可用的结果，以此类推，直到我得到一个理想的结果。
下面是一个简单的示例，它遍历所有结果并返回它找到的大于9的第一个值。(请注意，这不是我的真正任务。这只是
浏览 3提问于2016-04-14得票数 7
回答已采纳
我正在尝试使用JdbcTemplate对数据库进行一些简单的查询。我的方法正确吗？ @Async
public CompletableFuture<List<ResultClass1> query1() {
return CompletableFuture.completedFuture(jdbcTemplate.query("my sql",rowMap, paramter));
}
@Async
public CompletableFuture<List<ResultClass2> query2() {
return Co
浏览 19提问于2020-04-22得票数 0
我想在一个带有@Test注释的TestNG类中运行CompletableFuture。
下面是代码片段，main()方法递归地调用recursionFuture方法来完成特定的任务。现在，如果我以public static void main(String[] args))的身份使用main()，那么一切都会正常工作。但是，当我使用带有@Test注释的main()时，TestNG会在两者之间停止执行，并且不会执行整个任务。
如何让@Test等待recursionFuture完成所有任务？
我必须使用异步任务的CompletableFuture，也需要使用@Test。
任何帮助都将不胜感激。谢谢
浏览 6提问于2017-01-26得票数 3
我正面临着一个非常奇怪的问题。
我正在编写Vert.x，从处理程序中使用Vert.x的HttpClientRequest调用REST。现在我有了一个CompletableFuture，我正在HttpClientRequest的响应处理程序中完成它。稍后，我将使用CompletableFuture.get()。但是，每当调用get()方法时，主线程就会被阻塞(正如预期的那样)，但是它将永远被阻塞。我没有看到回调发生在我的响应处理程序上，而且它被永远卡住了。
这是代码：
import io.vertx.core.http.HttpClientRequest;
import io.vertx.cor
浏览 2提问于2018-10-05得票数 2
回答已采纳
当在中发生异常时，我试图设置一个缺省值，我通过handle方法使其工作，如下所示：
private static void testHandle() {
String name = null;
CompletableFuture<String> completableFuture
= CompletableFuture.supplyAsync(() -> {
if (name == null) {
throw new RuntimeException("Computation error!
浏览 1提问于2018-06-09得票数 3
回答已采纳
我试图在每个工作人员超时2秒的情况下停止许多Worker实例，我希望其中一些实例会失败。我想实现如下的目标，我知道这是一个糟糕的方法。我不能使用CompletableFuture.allOf()，因为它在第一个失败时停止。而且，我以前从未使用过CompletableFutures。我尝试了Executors.newFixedThreadPool(3).invokeAll()，但没有成功。
public interface Worker {
public String workerId();
public CompletableFuture<Worker> stop();
}
L
浏览 3提问于2020-03-24得票数 1
Uscase
假设我们使用CompletableFuture.runAsync(..)运行执行在runnable中，我们使用了试用资源块(无论发生什么情况，我们都会使用一些应该关闭的资源)，并且当执行在try块中没有完成时，我们会取消可完成的未来.通常停止执行，应该关闭的资源不关闭，AutoClosable的close()不被调用.
问题
这是一个java问题，还是有一种正确的方法？如果没有像使用期货(支持中断等)之类的麻烦事，如果它的预期行为，那么当不可中断的CompletableFuture被取消时，人们应该如何处理类似的情况呢？
“守则”
public class AutoClosa
浏览 4提问于2014-09-25得票数 7
回答已采纳
3回答
我有一个循环，它会无限地运行，直到我告诉它停止。我实际上正在使用requestAnimationFrame，还有更多的东西在使用，但下面的例子只是为了简化我的问题。
var _stop = false;
var loop = function () {
while (!_stop) {
if (some condition is met) {
stop();
}
/* Do something. */
loop();
}
};
function stop() {
_stop
浏览 1提问于2015-03-21得票数 3
假设我遇到了如下情况：
CompletableFuture<Object1> f1 = Class1.doSomething();
CompletableFuture<Object2> f2 = Class2.doSomethingElse(f1);
boolean b = doAnotherThing(f2);
其中Class2使用thenCompose()并以不同的对象类型返回
CompletableFuture<Object2> doSomethingElse(CompletableFuture<Object1> f) {
return f
浏览 4提问于2017-07-31得票数 0
回答已采纳
要并行或异步运行某些程序，我可以使用ExecutorService：<T> Future<T> submit(Runnable task, T result);或CompletableFuture Api:static <U> CompletableFuture<U> supplyAsync(Supplier<U> supplier, Executor executor); (假设我在这两种情况下都使用相同的执行器)
除了返回类型Future和CompletableFuture之外，还有什么显着的区别吗？或者什么时候使用什么？
如果我
浏览 3提问于2016-09-13得票数 49
回答已采纳
我正在使用一个返回CompletableFutures来查询设备的API (类似于)。
我需要用几个选项调用这个API来查询一个设备并找出它是什么--这基本上是试错，直到它成功。这些是我无法更改的嵌入式设备协议，但您可以将此过程看作与以下内容类似的工作：
你是苹果吗？
如果不是，那你是菠萝吗？
如果不是，那你是笔吗？
..。
虽然API使用期货，但在现实中，通信是串行的(通过同一条物理线路)，因此它们永远不会同步执行。一旦我知道了它是什么，我希望能够停止尝试，让来电者知道它是什么。
我已经知道，我只能得到一个未来的结果与any (见下文)，但这可能会导致更多的尝试，应该
浏览 2提问于2018-05-24得票数 2
回答已采纳
我有一段代码如下
protected List<AMQMessage> waitForReceivedRawMessageFromActiveMq(AMQConsumerMessageListener listener) {
CompletableFuture<List<AMQMessage>> completableFuture = CompletableFuture.supplyAsync(() -> {
while (listener.getMessageList().isEmpty()) {}
return listener.g
浏览 11提问于2020-11-18得票数 0
回答已采纳
我在for循环中调用一个异步方法，并将它的未来添加到一个列表中。我不确定为什么allOff不等待完成所有的未来并返回部分结果。看一下我的代码。 我有一个被重写的方法 @Overide
@Async
CompletableFuture<someType> fetchData()
{
returns new CompletableFuture<someType>();
} 我在一个for循环中使用不同的实例调用上面的方法。 获取实现一个接口的所有bean，该接口具有fetchData方法。 Map<String, SomeClass> allBeans =co
浏览 12提问于2019-10-14得票数 3
回答已采纳
我有一些像这样的服务回报CompletableFutures
Set<CompletableFuture<String>> futures = service.getSomething();
for (CompletableFuture<String> future : futures) {
System.out.println(future.get());
}
此代码打印值迭代顺序。但是我想要像使用CompletionService.那样的快速结果打印
Set<CompletableFuture<String>> futu
浏览 4提问于2017-06-16得票数 1
回答已采纳
简单地说。如何在JDK1.6或1.7中停止并释放线程？Javadoc说停止()是不可取的。停止/结束然后释放线程的正确方法是什么？
浏览 3提问于2013-11-07得票数 3
回答已采纳
2回答
核实完整期货清单的大小
、、、、
我有一个代码看起来类似于
public void myMethod(){
List<CompletableFuture<Void>> futures = new ArrayList<>();
//getQuestion, getAnswer, both returns a CompletableFuture<Void>
futures.add(getQuestion());
futures.add(getAnswer());
// make
浏览 0提问于2019-08-26得票数 0
回答已采纳
我第一次使用可完成的未来。我没有收到任何错误，但想了解我是否正确地使用它。
CompletableFuture<HashMap<String, String>> completableFuture = new CompletableFuture<>();
for (int iterator = 0; iterator < 10; iterator = iterator + 1)) {
int finalIterator = iter
浏览 16提问于2022-12-02得票数 0
这里有两个选择，只是有点混淆了哪一个是最好的。
选项1:
ExecutorService es = Executors.newFixedThreadPool(4);
List<Runnable> tasks = getTasks();
CompletableFuture<?>[] futures = tasks.stream()
.map(task -> CompletableFuture.runAsync(task, es))
.toArr
浏览 0提问于2018-09-02得票数 1
回答已采纳
3回答
如何使用5个CompletableFutures异步执行20个可运行任务(或1个任务20次)？
这就是我得到的：
Runnable task = () -> {
long startTime = System.currentTimeMillis();
Random random = new Random();
while (System.currentTimeMillis() - startTime < 3000) {
DoubleStream.generate(() -> random.nextDou
浏览 0提问于2018-04-15得票数 2
我正试图看到有目的地使用CompletableFuture导致堆栈溢出的行为，但是却发现它成功了，我的递归循环刚刚停止并退出，junit测试通过了。这不是我想要的行为。我想要一种快速失败的行为，这样我就知道如何修复我的代码。
@Test
public void testBlowTheStack() throws InterruptedException {
recurse(0);
System.out.println("done");
Thread.sleep(5000);
}
private void recurse(int counter) {
浏览 4提问于2016-04-26得票数 3
回答已采纳
我遇到了Java8 CompletableFuture.exceptionally方法的奇怪行为。如果我执行这段代码，它就能正常工作并打印java.lang.RuntimeException
CompletableFuture<String> future = new CompletableFuture<>();
future.completeExceptionally(new RuntimeException());
future.exceptionally(e -> {
System.out.println(e.getClass()
浏览 3提问于2014-12-12得票数 45
回答已采纳
1回答
我想跳过完整期货链的具体情况。我尝试了在上提出的解决方案，但似乎行不通。在这里，代码：
@RunWith(JUnit4.class)
public class ExceptionHandlingTests {
@Test
public void test1() {
CompletableFuture<Integer> result = new CompletableFuture<>();
CompletableFuture.runAsync(() -> {
System.out.println("Completing res
浏览 4提问于2018-01-08得票数 5
回答已采纳
1回答
如果这个问题对有经验的程序员来说太简单了，我道歉。我刚开始使用Petzold学习windows的基础知识，但我有过使用Mathematica和一些C和Labview编程的经验。
关于windows中的消息循环，我不理解的是，它看起来像是一个While循环，似乎在“普通”C程序中，只要条件保持为真，while循环就会运行，然后程序继续执行下一条指令，直到程序结束。我认为这就像是导致程序执行和结束的一系列事件，而不是Labview程序的相同哲学，在Labview程序中，时间和顺序不那么重要，除非用户介入，否则程序可能永远不会结束。
据我所知，在windows中，除非你中断程序，否则消息循环永远不会
浏览 5提问于2014-06-12得票数 0
1回答
流程为控制器层、->服务层
这里我从控制器层调用processLOBTransactions (异步方法)方法
如何将加入控制器层中的所有CompletableFuture响应？我的要求是在对来自控制器的每个list元素执行processLOBTransactions之后，在控制器层中，我想写日志之类的东西。
请大家就如何做到这一点提出建议。
**Controller Layer:**
class ControllerLayer{
pktransaction.getLineOfBusinessTransaction().stream().forEac
浏览 5提问于2021-02-07得票数 1
回答已采纳
我有以下代码：
public final class Start {
private static final CountDownLatch FINAL_THREAD = new CountDownLatch(1);
private static String getValue() {
System.out.println("Waiting...");
try {
Thread.sleep(Duration.ofSeconds(1).toMillis());
return
浏览 19提问于2021-05-13得票数 1
2回答
下面的示例取自
@Service
public class GitHubLookupService {
@Async
public CompletableFuture<User> findUser(String user) throws InterruptedException {
logger.info("Looking up " + user);
String url = String.format("https://api.github.com/users/%s", user);
User results =
浏览 5提问于2020-07-26得票数 0
回答已采纳
我在使用CompletableFuture时遇到了以下用例： public void someFunction () {
CompletableFuture.runAsync(() -> computations())
.exceptionally((err) -> {
log.info(err + "");
return null;
});
}
public void computations() {
list.stream.forEach(() -> otherFunction());
}
public v
浏览 211提问于2021-11-04得票数 0
回答已采纳
我在理解CompletableFuture时遇到了一些问题。我不理解get()方法。如果我错了，请纠正我，但它说“如果有必要，等待这个将来完成，然后返回结果。”那么，如果我没有返回任何结果，我就不必调用get方法了？请看下面的内容。即使我不调用get()方法，它仍然会执行它的工作。所以我把get()理解为如果将来返回一些它会有意义的东西，否则get()对于不返回任何东西的未来来说是不必要的。
//Since it does not return something two statements below do the same thing.
CompletableFuture.runAsy
浏览 0提问于2018-10-12得票数 1
我试图通过flink停止停止一项工作
flink stop [jobid]
但是，CLI引发错误，不允许我停止作业。我可以取消它。这里的原因是什么？
停止工作c7196bb1d21d679efed73770a4e4f9ed。
程序在以下异常情况下结束：
org.apache.flink.util.FlinkException: c7196bb1d21d679efed73770a4e4f9ed无法停止这项工作。在org.apache.flink.client.cli.CliFrontend.lambda$stop$5(CliFrontend.java:557) at org.apache.fl
浏览 1提问于2018-12-12得票数 0
回答已采纳
我正在通过CompletableFuture API学习并发性。假设我有两项任务:一项是250毫秒，另一项是2500毫秒。在以下代码中：
Supplier<List<Long>> supplyIds = () -> {
sleep(200);
return(Arrays.asList(1L, 2L, 3L));
};
Function<List<Long>, CompletableFuture<List<User>>>
浏览 7提问于2020-04-18得票数 1
回答已采纳
我试图使用CompletableFuture方法并行运行3个操作。现在，这3个操作返回不同的类型，因此需要分别检索数据。以下是我要做的事：
CompletableFuture<List<A>> aFuture = CompletableFuture.supplyAsync (() -> getAList());
CompletableFuture<Map<String,B> bFuture = CompletableFuture.supplyAsync (() -> getBMap());
CompletableFuture<Map&
浏览 9提问于2022-04-29得票数 2
因此，我决定开始在CompletableFuture中使用Java8，但我不知道这段代码有什么问题：
public static void main(String...strings) throws Exception {
final Supplier<User> makeUserSupplier = () -> makeUser();
final Supplier<String> uuidSupplier = () -> makeUUID();
final CompletableFuture<User> future
浏览 0提问于2019-01-24得票数 1
回答已采纳
我们正在使用wildfly 10 /2节点设置集群环境。我们添加了一个新的缓存容器和名为'userSessionData‘的复制缓存，用于在两台服务器之间共享数据。使用Standalone-full-ha.xml。在我们的开发环境中，一切都运行良好。
但在客户端预生产环境中，我们经常会遇到复制超时异常。在我们的开发环境中，我们使用默认的远程超时设置，即17500毫秒，我认为它对应于复制超时。在客户端预生产环境中，我们已将其增加到60000毫秒，即1分钟，但仍然经常收到相同的异常。超时问题场景之一：-当用户登录到应用程序时，我们将用户会话详细信息放入缓存中。在写入缓存期间，发生异常。
我
浏览 0提问于2017-08-01得票数 1
1回答
我正在调试内存泄漏，不得不深入到CompletableFuture内部。有一段代码(CompletableFuture.uniComposeStage)：
CompletableFuture<V> g = f.apply(t).toCompletableFuture();
...
CompletableFuture<V> d = new CompletableFuture<V>();
UniRelay<V> copy = new UniRelay<V>(d, g);
g.push(copy);
copy.tryFire(SYNC);
浏览 4提问于2017-06-13得票数 5
回答已采纳
我创建了一些任务，如下所示(这只是为了演示正常的网络调用)：
public class RandomTask implements Function<String, String> {
private int number;
private int waitTime;
private boolean throwError;
public RandomTask(int number, int waitTime, boolean throwError) {
this.number = number;
this.waitT
浏览 0提问于2018-11-15得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
