Java中如何实现异步调用

Java中如何实现异步调用，相信很多没有经验的人对此束手无策，为此本文总结了问题出现的原因和解决方法，通过这篇文章希望你能解决这个问题。

@Test一、创建线程

public void test0() throws Exception {  System.out.println("main函数开始执行");  Thread thread=new Thread(new Runnable() {    @Override    public void run() {      System.out.println("===task start===");      try {        Thread.sleep(5000);      } catch (InterruptedException e) {        e.printStackTrace();      }      System.out.println("===task finish===");    }  });  thread.start();  System.out.println("main函数执行结束");}

二、Future

jdk8之前的实现方式，在JUC下增加了Future，从字面意思理解就是未来的意思，但使用起来却着实有点鸡肋，并不能实现真正意义上的异步，获取结果时需要阻塞线程，或者不断轮询。

@Testpublic void test1() throws Exception {    System.out.println("main函数开始执行");    ExecutorService executor = Executors.newFixedThreadPool(1);    Future<Integer> future = executor.submit(new Callable<Integer>() {        @Override        public Integer call() throws Exception {            System.out.println("===task start===");            Thread.sleep(5000);            System.out.println("===task finish===");            return 3;        }    });    //这里需要返回值时会阻塞主线程，如果不需要返回值使用是OK的。倒也还能接收    //Integer result=future.get();    System.out.println("main函数执行结束");    System.in.read();}

三、CompletableFuture

使用原生的CompletableFuture实现异步操作，加上对lambda的支持，可以说实现异步任务已经发挥到了极致。

@Testpublic void test2() throws Exception {    System.out.println("main函数开始执行");    ExecutorService executor = Executors.newFixedThreadPool(2);    CompletableFuture<Integer> future = CompletableFuture.supplyAsync(new Supplier<Integer>() {        @Override        public Integer get() {            System.out.println("===task start===");            try {                Thread.sleep(5000);            } catch (InterruptedException e) {                e.printStackTrace();            }            System.out.println("===task finish===");            return 3;        }    }, executor);    future.thenAccept(e -> System.out.println(e));    System.out.println("main函数执行结束");}

四、Spring的Async注解

使用spring实现异步需要开启注解，可以使用xml方式或者Java config的方式。

xml方式：

<task:annotation-driven executor="executor" /><task:executor id="executor"        pool-size="2" 线程池的大小        queue-capacity="100" 排队队列长度         keep-alive="120" 线程保活时间（单位秒）        rejection-policy="CALLER_RUNS" 对拒绝的任务处理策略 />

java方式：

@EnableAsyncpublic class MyConfig {    @Bean    public TaskExecutor executor(){        ThreadPoolTaskExecutor executor=new ThreadPoolTaskExecutor();        executor.setCorePoolSize(10); //核心线程数        executor.setMaxPoolSize(20);  //最大线程数        executor.setQueueCapacity(1000); //队列大小        executor.setKeepAliveSeconds(300); //线程最大空闲时间        executor.setThreadNamePrefix("fsx-Executor-"); //指定用于新创建的线程名称的前缀。        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());        return executor;    }}

（1）@Async

@Testpublic void test3() throws Exception {    System.out.println("main函数开始执行");    myService.longtime();    System.out.println("main函数执行结束");} @Asyncpublic void longtime() {    System.out.println("我在执行一项耗时任务");    try {        Thread.sleep(5000);    } catch (InterruptedException e) {        e.printStackTrace();    }    System.out.println("完成");}

（2）AsyncResult

如果需要返回值，耗时方法返回值用AsyncResult包装。

@Testpublic void test4() throws Exception {    System.out.println("main函数开始执行");    Future future=myService.longtime2();    System.out.println("main函数执行结束");    System.out.println("异步执行结果："+future.get());} @Asyncpublic Future longtime2() {    System.out.println("我在执行一项耗时任务");    try {        Thread.sleep(8000);    } catch (InterruptedException e) {        e.printStackTrace();    }    System.out.println("完成");    return new AsyncResult<>(3);}

看完上述内容，你们掌握Java中如何实现异步调用的方法了吗？如果还想学到更多技能或想了解更多相关内容，欢迎关注编程网行业资讯频道，感谢各位的阅读！