CompletableFuture的acceptEitherAsync:哪个线程跑的最快用那个

简介: CompletableFuture的acceptEitherAsync:哪个线程跑的最快用那个acceptEitherAsync:假设两个线程A和B,不确定A和B哪个最快执行完毕返回, 但是需要使用最快执行完毕的线程返回的结果。

CompletableFuture的acceptEitherAsync:哪个线程跑的最快用那个


acceptEitherAsync:假设两个线程A和B,不确定A和B哪个最快执行完毕返回, 但是需要使用最快执行完毕的线程返回的结果。那么就可以使用代码:

private void test() {
    System.out.println("开始...");

    CompletableFuture.supplyAsync(new Supplier<String>() {
        @Override
        public String get() {
            try {
                TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

            System.out.println("返回 A");
            return "A";
        }
    }).acceptEitherAsync(CompletableFuture.supplyAsync(new Supplier<String>() {
        @Override
        public String get() {
            try {
                TimeUnit.SECONDS.sleep(5);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

            System.out.println("返回 B");
            return "B";
        }
    }), new Consumer<String>() {
        @Override
        public void accept(String s) {
            System.out.println("最快返回的:" + s);
        }
    });
}

代码运行输出:

07-02 14:28:02.766 30166-30166/zhangphil.test I/System.out: 开始...
07-02 14:28:03.770 30166-30193/zhangphil.test I/System.out: 返回 A
07-02 14:28:03.772 30166-30193/zhangphil.test I/System.out: 最快返回的:A
07-02 14:28:07.771 30166-30194/zhangphil.test I/System.out: 返回 B


线程A仅需1秒即返回执行结果,而线程B需要长达5秒执行完毕才返回结果,那么就采用线程A执行的结果。


相关文章
|
监控 安全 算法
Thread入门与线程方法详解及多线程安全
Thread入门与线程方法详解及多线程安全
76 0
|
5月前
|
监控 Java
多线程线程池问题之创建线程如何解决
多线程线程池问题之创建线程如何解决
|
Java 调度
线程池如何知道一个线程的任务已经执行完成
线程池如何知道一个线程的任务已经执行完成
567 0
|
Java API
既然阻塞 I/O 会使线程休眠,为什么 Java 线程状态却是 RUNNABLE?
使用 Java 阻塞 I/O 模型读取数据,将会导致线程阻塞,线程将会进入休眠,从而让出 CPU 的执行权,直到数据读取完成。这个期间如果使用 jstack 查看线程状态,却可以发现Java 线程状态是处于 RUNNABLE,这就和上面说的存在矛盾,为什么会这样? 上面的矛盾其实是混淆了操作系统线程状态与 Java 线程状态。这里说的线程阻塞进入休眠状态,其实是操作系统层面线程实际状态。而我们使用 jstack 查看的线程状态却是 JVM 中的线程状态。 线程是操作系统中一种概念,Java 对其进行了封装,Java 线程本质上就是操作系统的中线程,其状态与操作系统的状态大致相同,但还是存在
既然阻塞 I/O 会使线程休眠,为什么 Java 线程状态却是 RUNNABLE?
|
Java
【java】主线程等待子线程执行结束后再执行,线程池
【java】主线程等待子线程执行结束后再执行,线程池
189 0
使用ThreadPoolExecutor,当提交线程超过maximumPoolSize 会阻塞主线程吗?
使用ThreadPoolExecutor,当提交线程超过maximumPoolSize 会阻塞主线程吗?
185 0
使用ThreadPoolExecutor,当提交线程超过maximumPoolSize 会阻塞主线程吗?
JUC之线程顺序执行的2种方式【CountDownLatch、Thread.join()】
JUC之线程顺序执行的2种方式【CountDownLatch、Thread.join()】
JUC之线程顺序执行的2种方式【CountDownLatch、Thread.join()】
【线程】并发流程控制的同步工具-CountDownLatch
通常我们都会利用并行来优化性能,但是对于串行化的业务,可能需要按顺序执行,那我们怎么才能处理呢?
|
存储 安全 容器
【多线程】阻塞线程| 一图看懂ArrayBlockingQueue源码
是一个数组实现的环形队列,经常会使用并发容器用于存储多线程间的共享数据,这样不仅可以保证线程安全,还可以简化各个线程操作
Java——多线程高并发系列之创建多线程的四种方式(Thread、Runnable、Callable、线程池)
Java——多线程高并发系列之创建多线程的四种方式(Thread、Runnable、Callable、线程池)
Java——多线程高并发系列之创建多线程的四种方式(Thread、Runnable、Callable、线程池)

热门文章

最新文章