Java Future并发模式

妖狐艹你老母 2022-02-05 07:59 210阅读 0赞

### Future与线程池区别 ###

Future跟Callable一样都会返回值，而线程池不会返回值

### CompletableFuture ###

直接跳到CompletableFuture。

大概几个方法异步运行：

### CompletableFuture.runAsync ###

没有返回值

### CompletableFuture.supplyAsync ###

有返回值

### 获取值 ###

CompletableFuture get()函数

### 异常捕获 ###

exceptionally

CompletableFuture.supplyAsync(
                            () -> b(string)).exceptionally(new Function<Throwable, String>() {
                                @Override
                                public String apply(Throwable throwable) {
                                    System.out.println("exceptionally - apply ：" + throwable.toString());
                                    return "发生异常！";
                                }
                            })

还有很多函数可以调用，这里不一一列举

如何像多线程一样，进行异步处理

String[] stringList = {"1", "2"};
            List<String> list = Arrays.asList(stringList);
    
            List<CompletableFuture<String>> futures = list.stream()
                    .map(string -> CompletableFuture.supplyAsync(
                            () -> b(string)).exceptionally(new Function<Throwable, String>() {
                                @Override
                                public String apply(Throwable throwable) {
                                    System.out.println("exceptionally - apply ：" + throwable.toString());
                                    return "发生异常！";
                                }
                            })
                    ).collect(Collectors.toList());
    
            futures.stream().forEach(f -> {
                try {
                    System.out.println(f.get());
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } catch (ExecutionException e) {
                    e.printStackTrace();
                }
            });

public static String b(String x) {
            //int i = 1 / 0;
    
            return x;
        }

使用[Java8 Stream流][Java8 Stream]操作

### allof ###

没有返回值

CompletableFuture有一个allof函数，合并很多个CompletableFuture然后输出结果,这个是所有future执行完执行的操作

### anyof ###

有返回值

但是这个只要有一个Future执行完之后就会进行操作，所以根本做不了说返回多个Future

[Java8 Stream]: https://blog.csdn.net/weixin_38336658/article/details/89840012