标签：创建 executor System 任务 线程 res println out

runAfterEither:不能获取完成的线程的返回结果，自身也没有返回结果
* acceptEither:可以获取线程的返回结果，自身没有返回结果
* applyToEither:既可以获取线程的返回结果，自身也有返回结果

public class CompletableFutureDemo04 {
    private static ThreadPoolExecutor executor=new ThreadPoolExecutor(5,
            50, 
            10,
            TimeUnit.SECONDS, 
            new LinkedBlockingQueue<>(),
            Executors.defaultThreadFactory(),
           new  ThreadPoolExecutor.AbortPolicy());
    //运行时发现 线程会阻塞 等待新的任务去调度
    
    /**
     * 
     * @throws ExecutionException
     * @throws InterruptedException
     */
    public static void main(String[] args) throws Exception {
        CompletableFuture<Integer> future1 = CompletableFuture.supplyAsync(() -> {
            System.out.println("线程1开始了" + Thread.currentThread().getName());
            int i = 100 / 10;
            System.out.println("线程1结束了" + Thread.currentThread().getName());
            return i;
        }, executor);
    
        CompletableFuture<Integer> future2 = CompletableFuture.supplyAsync(() -> {
            System.out.println("线程2开始了" + Thread.currentThread().getName());
            int i = 100 / 5;
            try {
                Thread.sleep(5000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("线程2结束了" + Thread.currentThread().getName());
            return i;
        }, executor);
      //runAfterEitherAsync 是不能获取前面线程的返回结果 自身也没有返回结果
        future1.runAfterEitherAsync(future2, () -> {
            System.out.println("任务3执行了");
        },executor);
        
        //acceptEitherAsync  自身没有返回结果  接收上面两个线程其中一个 结果就能正常运行  并且线程1和线程2的返回泛型类型必须相同 可以写成Object
        future1.acceptEitherAsync(future2, res -> {
            System.out.println("res = " + res);
        }, executor);
    
        CompletableFuture<String> stringCompletableFuture = future1.applyToEitherAsync(future2, res -> {
            System.out.println("res = " + res);
            return res + "--->ok";
        }, executor);
    
        System.out.println("stringCompletableFuture:"+stringCompletableFuture.get());
    }
}

标签：创建,executor,System,任务,线程,res,println,out
来源： https://www.cnblogs.com/Lcch/p/16354268.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。