异步任务的创建与回调

2022-06-07 20:03:11 阅读：116 来源： 互联网

标签：异步创建 System CompletableFuture res println 线程回调 out

package com.msb.mall.mallsearch;

import java.util.concurrent.*;

/**
 * @author lcc
 * @version V1.0
 * @Package com.msb.mall.mallsearch
 * @date 2022/6/7 19:01
 * CompletableFuture  介绍
 */
public class CompletableFutureDemo {
    private static ThreadPoolExecutor executor=new ThreadPoolExecutor(5,
            50, 
            10,
            TimeUnit.SECONDS, 
            new LinkedBlockingQueue<>(),
            Executors.defaultThreadFactory(),
           new  ThreadPoolExecutor.AbortPolicy());
    //运行时发现 线程会阻塞 等待新的任务去调度
    
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        System.out.println("主线程开始了");
        //获取CompletableFuture对象
        CompletableFuture<Void> voidCompletableFuture = CompletableFuture.runAsync(() -> {
            System.out.println("线程开始了");
            int i=100/50;
            
            System.out.println("线程结束了");
        },executor);
        
        System.out.println("主线程结束了");
        
        System.out.println("------------");
        CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {
            System.out.println("线程开始了");
            int i = 100 / 10;
            System.out.println("线程结束了");
            return i;
        }, executor).handleAsync((res, throwable) -> {
            System.out.println("res = " + res+"  throwable="+throwable);
            return res*10;//这个既可以获得上面执行的结果 也可以修改 返回值
            
        });
        
        //可以处理异步任务之后的操作
        
        System.out.println("获取线程的返回结果是"+future.get());
    }
    
   /* public static void main(String[] args) throws ExecutionException, InterruptedException {
        System.out.println("主线程开始了");
        //获取CompletableFuture对象
        CompletableFuture<Void> voidCompletableFuture = CompletableFuture.runAsync(() -> {
            System.out.println("线程开始了");
            int i=100/50;
    
            System.out.println("线程结束了");
        },executor);
    
        System.out.println("主线程结束了");
        
        System.out.println("------------");
        CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {
            System.out.println("线程开始了");
            int i = 100 / 10;
            System.out.println("线程结束了");
            return i;
        }, executor).whenCompleteAsync((res, exec) -> {
            System.out.println(res);//可以拉取到上面的执行结果
            System.out.println(exec);//获取到异常
            
        }).exceptionally(res -> {//捕捉到异常 只有发生异常后才会调用此方法 可以改变方法返回结果 然后进行处理
            System.out.println("res"+res);
            return 10;
        });
        //可以处理异步任务之后的操作
    
        System.out.println("获取线程的返回结果是"+future.get());
    }*/
}

* whenComplete 可以获取异步任务的返回值和抛出的异常信息，但是不能修改返回结果
* execptionlly 当异步任务跑出了异常后会触发的方法，如果没有抛出异常该方法不会执行
* handle 可以获取异步任务的返回值和抛出的异常信息，而且可以显示的修改返回的结果

标签：异步,创建,System,CompletableFuture,res,println,线程,回调,out
来源： https://www.cnblogs.com/Lcch/p/16353131.html

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

ICode9

异步任务的创建与回调