我正在使用下面的示例代码，其中CompletableFuture链接了多次，我想知道为什么当抛出异常时，链接代码不会在堆栈跟踪中多次出现。
package com.yannick;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.CompletionException;
public class AsyncExceptionNestingTestMain {
public static void main(String[] args) throws Exception {
浏览 16提问于2019-11-15得票数 1
回答已采纳
2回答
当将两个独立的CompletableFuture与返回第三个BiFunction的BiFunction组合时，我试图避免嵌套one。目前，使用thenCombine()并不会削减它：
// What I have
public CompletableFuture<CompletableFuture<C>> doStuff() {
CompletableFuture<A> aFuture = makeSomeA();
CompletableFuture<B> bFuture = makeSomeB();
Completabl
浏览 4提问于2017-02-13得票数 9
回答已采纳
我期望从下面的代码，由于超时，完全期货将停止处理。但我可以看出取消没有任何效果。
public class CompletableFutureTest {
public static void main(final String[] args) {
ExecutorService executor = Executors.newFixedThreadPool(10);
CompletableFuture completableFuture;
CompletableFuture completableFuture2;
co
浏览 10提问于2022-05-05得票数 0
我有以下方法：
@EnableAsync
@Service
Class MyService{
private String processRequest() {
log.info("Start processing request");
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
log.info(&#
浏览 1提问于2020-11-06得票数 5
回答已采纳
我对这段代码有疑问：
@Async
public CompletableFuture<String> doFoo() {
CompletableFuture<String> fooFuture = new CompletableFuture<>();
try {
String fooResult = longOp();
fooFuture.complete(fooResult);
} catch (Exception e) {
fooFuture.completeException
浏览 1提问于2017-11-17得票数 27
回答已采纳
我读到过CompletableFuture有能力将多个期货与runAfterBoth合并，但如果我想合并超过两个呢？
CompletableFuture<Boolean> a = new CompletableFuture<>();
CompletableFuture<Boolean> b = new CompletableFuture<>();
CompletableFuture<Boolean> c = new CompletableFuture<>();
List<CompletableFuture<B
浏览 1提问于2016-12-10得票数 0
回答已采纳
我想要一些关于使用CompletableFuture的好方法的建议。
如果我有一个整数列表，对于每个整数，我想执行3个操作，这需要一些时间。例如，乘法、除法和减法。
对于结果，它应该是map，其中key是整数，value是具有三个操作结果的列表。
场景1:如果我想在处理完一个整数后将结果写到map中，那么下面是不是一个很好的方法呢？
for (int x : nums) {
CompletableFuture<Integer> multiply = CompletableFuture.supplyAsync(() -> multiply(x));
Completabl
浏览 3提问于2020-03-04得票数 0
在不同版本的java下，我从相同的代码片段中得到不同的输出。我无法在打开的jdk bug跟踪器上找到相关的票证。
CompletableFuture<String> completableFuture = new CompletableFuture<>();
completableFuture.complete("xxx");
completableFuture.thenCompose(str -> {
CompletableFuture<String> completableFuture1 = new Completable
浏览 4提问于2016-08-08得票数 2
回答已采纳
我想异步调用外部api 3次，然后等待它们返回。我的代码如下所示：
public ResponseClass callApi(xxx) {
// ... other code
ResponseClass response = restTemplate.postForEntity(
requestUrl,
httpEntity,
ResponseClass.class
).getBody();
return response;
}
public void otherMethod() {
Comple
浏览 10提问于2021-08-15得票数 1
我希望等待多个事件，并决定尝试用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
回答已采纳
我想知道使用zip使用CompletableFuture的官方机制是什么。到目前为止，我只使用thenCombine操作符。这是我的例子。
@Test
public void zip() throws InterruptedException {
CompletableFuture<Either<Integer, String>> completableFuture = CompletableFuture.supplyAsync(this::getValue);
CompletableFuture<Either<Integer, String
浏览 0提问于2017-10-17得票数 1
1回答
private void processEvents(List<Object> events) {
CompletableFuture<Void> completableFuture = CompletableFuture.runAsync(
() -> processEventsAsynchronously(events));
while (!completableFuture.isDone() || completableFuture.isCancelled() || completableFu
浏览 15提问于2021-12-04得票数 1
例如，我有这样的方法：
public CompletableFuture<Page> getPage(int i) {
...
}
public CompletableFuture<Document> getDocument(int i) {
...
}
public CompletableFuture<Void> parseLinks(Document doc) {
...
}
我的流量：
List<CompletableFuture> list = IntStream
.range(0, 10)
.ma
浏览 2提问于2016-09-30得票数 6
在CompletableFuture.supplyAsync()的生产环境中发现了一个问题，我们有一个批处理方法，如下所示：
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
import java.util.stream.Collectors;
public class CompletableFutureProblem {
public voi
浏览 5提问于2020-11-21得票数 3
回答已采纳
给定存储库类，它返回一个单独的：
Single<SomeObject> find()
和返回浮点数的CompletableFuture：
CompletableFuture<Long> completableFuture
我想首先调用存储库方法，根据结果，我需要调用completableFuture。这是我的代码：
repository.find()
.flatMap(s -> {
CompletableFuture<Long> completableFuture = serviceReturningCo
浏览 1提问于2019-12-02得票数 0
回答已采纳
1回答
如何将复杂的未来和流一起使用
、、、、
我想同时使用CompletableFuture和Stream。类似于将CompletableFuture<Stream<String>>转换为CompletableFuture<Stream<Team>>。
我做过类似的事情，从CompletableFuture<String>到CompletableFuture<Integer>。
CompletableFuture<Stream<String>> getMostPopularTeamNames(int maxResults) {
Comp
浏览 0提问于2019-07-01得票数 3
回答已采纳
3回答
嵌套期货未执行
、、
我遇到了一个奇怪的情况。我正在摆弄CompletableFuture，当运行以下代码时，我得到了意想不到的结果：
public static void main(String[] args) {
CompletableFuture<CompletableFuture<CompletableFuture<CompletableFuture<CompletableFuture<CompletableFuture<Object>>>>>> completableFutureCompletableFuture =
浏览 4提问于2017-02-20得票数 3
回答已采纳
我有一个返回CompletableFuture<T>的doTransmit方法。我想在一个循环中调用doTransmit，收集所有的CompletableFuture<T>并将其转换为一个CompletableFuture<List<T>>，当所有收集的List<T>都已被解析时，它将使用CompletableFuture<T>进行解析。
CompletableFuture<DeliveryResponse> doTransmit(Notification notification, Receiver rece
浏览 2提问于2019-01-25得票数 1
由于以下错误，我在使用getPrice()方法返回汽车价格值时遇到了问题：
no instance(s) of type variable(s) U exist so that CompletableFuture<U> conforms to Double inference variable U has incompatible bounds: equality constraints: Double lower bounds: CompletableFuture<U81345>
我希望getPrice返回CompletableFuture<Double>
浏览 11提问于2022-09-20得票数 3
回答已采纳
我正在尝试将List<CompletableFuture<X>>转换为CompletableFuture<List<T>>。这是非常有用的，因为您有许多异步任务，并且您需要获得所有这些任务的结果。
如果其中任何一个失败了，那么最终的未来就会失败。我就是这样实施的：
public static <T> CompletableFuture<List<T>> sequence2(List<CompletableFuture<T>> com, ExecutorService exec) {
浏览 6提问于2015-05-04得票数 89
回答已采纳
我正在尝试在AWS EMR群集上启动Flink批处理作业，并获得：
The program finished with the following exception:
org.apache.flink.client.program.ProgramInvocationException: Could not retrieve the execution result. (JobID: c7362754c49bdae8e9a46748d47bc180)
at org.apache.flink.client.program.rest.RestClusterClient.submitJob
浏览 524提问于2018-12-14得票数 4
回答已采纳
1回答
我正在测试CompletableFuture是如何工作的。我对如何并行执行任务感兴趣：
try {
CompletableFuture one = CompletableFuture.runAsync(() -> {
throw new RuntimeException("error");
});
CompletableFuture two = CompletableFuture.runAsync(() -> System.out.println("2"));
浏览 0提问于2019-03-23得票数 2
回答已采纳
我想通过rest停止一个flink任务，然后发送请求：，然后得到resoponse：
{
"request-id": "29c559399243c817055ebbaf7431a8d2"
}
然后我发送请求：，我得到了回复：(部分)
{
"status": {
"id": "COMPLETED"
},
"operation": {
"failure-cause": {
"class":
浏览 3提问于2022-01-07得票数 0
回答已采纳
我正在异步执行三个任务 CompletableFuture<IStoryDetail> iStoryDetailCompletableFuture = CompletableFuture.supplyAsync(()->storyRepository.getStoryDetails(id));
CompletableFuture<List<Comment>> iCommentFuture = CompletableFuture.supplyAsync(() -> commentRepository.getComments(id));
C
浏览 11提问于2020-03-19得票数 0
我希望将一个Runnable封装在要异步计算的CompletableFuture中，但要控制计算什么时候开始和结束。我创建了一个带有CompletableFuture的CountDownLatch来阻止处理，但是下面的代码段会抛出一个错误：
CountDownLatch countDownLatch = new CountDownLatch(1);
CompletableFuture completableFuture = CompletableFuture.runAsync(() -> {
try {
countDownLatch.await();
}
浏览 4提问于2019-09-19得票数 3
回答已采纳
2回答
下面的代码中提到的每个"CompletableFuture.runAsync“都做了一些计算，我希望每次调用"CompletableFuture.runAsync”时都能得到结果。换句话说，我希望"future0、future1、future2、future3“中的每一个都分别包含对"CompletableFuture.runAsync”的每个调用的结果。
我怎么能这么做。
*更新
我的要求是，对于每次调用CompletableFuture.runAsync，我都会进行一些计算，并且应该返回这些值的ArrayList。在CompletableFuture.run
浏览 3提问于2015-05-08得票数 3
回答已采纳
我目前正在使用CompletableFuture supplyAsync()方法向公共线程池提交一些任务。下面是代码片段：
final List<CompletableFuture<List<Test>>> completableFutures = resolvers.stream()
.map(resolver -> supplyAsync(() -> task.doWork()))
.collect(toList());
CompletableFuture.allOf(completableFutures.t
浏览 12提问于2018-09-17得票数 11
回答已采纳
我不确定它以前是否有效，但我今天更新到AndroidStudio4.1，然后尝试启动它，结果却看到了下面的崩溃。
即使当我从%appdata%\Google\AndroidStudio4.1\plugins中删除所有内容时，也会发生崩溃。似乎问题在于JetBrains安卓插件本身？
Internal error. Please refer to https://code.google.com/p/android/issues
java.util.concurrent.CompletionException: com.intellij.diagnostic.PluginException: C
浏览 4提问于2021-01-17得票数 0
回答已采纳
给予：
public static <T> CompletableFuture<? extends List<? extends T>> supplyAllOf(
List<? extends CompletableFuture<? extends T>> input)
{
return CompletableFuture.allOf(input.toArray(new CompletableFuture<?>[input.size()])).
thenApply(ignored ->
浏览 0提问于2018-03-06得票数 4
回答已采纳
假设我们有两个执行者，1和2。
我们可以在执行以下操作时配置要使用的执行器
CompletableFuture<Integer> cf1 = CompletableFuture.supplyAsync(()-> {return 1;}, executor1) //executor1
CompletableFuture<Integer> cf2 = CompletableFuture.supplyAsync(()-> {return 2;}, executor1) //executor1
CompletableFuture<Integer> cf3
浏览 0提问于2018-04-21得票数 6
回答已采纳
我有两个服务电话：
String call1() { ... return "ok"; }
void call2(String) { ... }
我知道CompletableFuture使用回调的基本方法是
CompletableFuture<Void> future = CompletableFuture
.supplyAsync(() -> call1())
.thenAccept(s -> call2(s));
future.join();
如果我将两个链接的CompletableFutures分开，比如：
CompletableFuture<
浏览 0提问于2018-09-01得票数 4
我创建了一个测试类。我创建了这样一个静态ExecutorService：
private static ExecutorService service = Executors.newFixedThreadPool(4);
，我用@AfterClass函数结束
@AfterClass
public static void afterClass(){
service.shutdown();
try {
if (!service.awaitTermination(1000, TimeUnit.MILLISECONDS)){
service.sh
浏览 0提问于2018-02-09得票数 1
1回答
我是Java8的新手，我有这段代码
for (Menu menu : resto1.getMenu()) {
MainIngredient mainIngredient = MainIngredient.getMainIngredient(menu.getName());
}
我想要重构以使它更快，我想将它转换为
List<CompletableFuture<MainIngredient>>
我试过了
List<CompletableFuture<MainIngredient>> priceFutureList = resto1.getM
浏览 1提问于2018-11-30得票数 2
回答已采纳
我试图从一个将CompletableFuture<List>返回到每个list元素的另一个方法中退出，在这个方法中，扇依次返回一个CompletableFuture。之后，我想从列表中生成的期货返回一个CompletableFuture.allOf。
本质上，我有以下方法(假设它们在它们自己的服务类中，我只是为了简洁起见将它们组合在一起)：
@Async
public CompletableFuture<List<File>> getMatchingCsvFrom(Path directory, Pattern pattern) {
...some
浏览 8提问于2022-07-12得票数 -1
回答已采纳
具有以下划痕代码：
public static void main(String[] args) throws ExecutionException, InterruptedException {
CompletableFuture<Void> process1 = CompletableFuture.runAsync(() -> {
System.out.println("Process 1 with exception");
throw new RuntimeException("Exception 1"
浏览 1提问于2020-02-10得票数 4
回答已采纳
1回答
不打印并发调用的跟踪标识
、、、
在日志中，对于并发调用，没有打印跟踪和span id。但对于其他电话，我可以看到它被打印出来了。
下面是我的密码。
@RestController
public class GetStudent implements IGetStudent {
private static final Logger log = LoggerFactory.getLogger(GetStudent.class);
@Autowired
private IGetStudentService getStudentService;
@Override
@RequestMap
浏览 7提问于2022-03-23得票数 0
回答已采纳
当在中发生异常时，我试图设置一个缺省值，我通过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
回答已采纳
我有以下代码： private fun genericFunction(): CompletableFuture<Location?> {
val completableFuture = CompletableFuture<Location?>()
Executors.newCachedThreadPool().submit {
val fusedLocationClient = LocationServices.getFusedLocationProviderClient(this)
fusedLo
浏览 25提问于2021-04-14得票数 0
回答已采纳
我想知道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
回答已采纳
我将从java中的CompletableFuture概念开始。我有一个需要在Map<String, CompletableFuture<Object>>中填充值的用例。
假设有一个学生实体类和一个ConcurrentMap<String, CompletableFuture<Student>>。我尝试通过以下方式将学生条目填充到映射中：
Student student = new Student();
ConcurrentMap<String, CompletableFuture<Student>> studentMap
浏览 2提问于2020-07-11得票数 0
对不起，如果有人有更好的主意，我愿意接受建议。
我在玩CompletableFuture，偶然发现了一些奇怪的东西。
假设您有两个类：A和B，其中有B extends A，因此B是A的一个子类型。
现在，让我们声明一个CompletableFuture
CompletableFuture<A> promiseofA = CompletableFuture.supplyAsync(() -> new B());
这是因为B是A的一个子类型，它符合CompletableFuture的声明。现在，如果我想添加一个exceptionally步骤，那么我就有一个编译异常：
Comple
浏览 4提问于2016-12-14得票数 2
回答已采纳
2回答
我有一个这样的手术， public void createFuture() {
CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> 5);
future.thenApply(i -> {
if (i == 5) {
System.out.println("hello, i equals to 5 so expensive operations are unnecessary");
}
浏览 23提问于2020-01-02得票数 3
我有以下内容：
private JobInfo aggregateJobInfo() {
final JobsResult jobsResult = restClient().getJobs();
final List<String> jobIds = extractJobIds(jobsResult);
//fetch details, exceptions and config for each job
final List<JobDetails> jobDetails = jobIds.stream().map(jobId -&g
浏览 0提问于2016-06-26得票数 3
回答已采纳
我正在为实现CompletableFuture的类编写Junit测试。我试图模拟这段代码，但是测试在CompletableFuture.allOf(future1,future2).join();上被无限地卡住了。
我在课堂上写的junit：
class Sample{
@Autowired
Executor executor;
/*
piece of code
*/
void SampleMethod(request){
/*
some piece of code
*/
CompletableFuture<Obj1>
浏览 29提问于2022-11-27得票数 0
当我在配置步骤之前将未来保存到变量中时，它为什么不起作用？
@Test
void simple() {
CompletableFuture<String> future = CompletableFuture.supplyAsync(this::throwException)
.exceptionally(throwable -> HANDLED);
assertEquals(HANDLED, future.join());
}
@Test
void withVar() {
CompletableFuture<Strin
浏览 1提问于2021-12-01得票数 1
回答已采纳
我正在回顾来自CompletableFuture的操作符CompletableFuture，但是当我试图组合多个CompletableFuture对象时，我遇到了一些问题。
示例：
CompletableFuture<List<String>> completableFuture =
CompletableFuture.supplyAsync(() -> fetch.andThen(log).apply(url1))
.thenCombine(CompletableFuture.supplyAsync(() -> fetch.
浏览 2提问于2019-10-20得票数 2
回答已采纳
我有一个问题，循环中的CompletableFuture任务不是并行运行的，而是同步运行的：
List<List<File>> filesLists = divideArrayIntoChunks(Arrays.asList(filesArray), 10);
// number of tasks
int numberOfTasks = filesLists.size();
List<CompletableFuture<TreeMap<String, HashMap<String, Intege
浏览 0提问于2020-11-22得票数 1
这样做是可行的：
public Long getMaxSalary(List<CompletableFuture<EmployeeData>> futures) {
CompletableFuture<Void> allDoneFuture = CompletableFuture.allOf(futures.toArray(new CompletableFuture[futures.size()]));
CompletableFuture<List<EmployeeData>> employeeDataList = allDoneF
浏览 0提问于2018-05-24得票数 0
回答已采纳
public class A{
@Autowired
B b;
public List<String> method1(){
CompletableFuture<List<String>> completableFuture = b.getCompletableFutureList();
// further processing
// returning a list of strings
return completableFuture.get();
}
浏览 28提问于2020-04-29得票数 1
回答已采纳
在我的应用中有三种不同的方法。所有的人都会返回CompletableFuture<SomeType>。我想并行执行方法1和方法2。在完成方法1和方法2之后，我想用方法1和方法2返回值的参数触发方法3。
代码示例：
CompletableFuture<Request> future1 = RequestConverter.Convert(requestDto);
CompletableFuture<String> future2 = tokenProvider.getAuthToken();
CompletableFuture<CompletableF
浏览 5提问于2018-01-09得票数 7
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
