Java实现异步调用

本文内容纲要：

-一、创建线程 -二、Future -三、CompletableFuture -四、Spring的Async注解 -

一、创建线程

@Test publicvoidtest0()throwsException{ System.out.println("main函数开始执行"); Threadthread=newThread(newRunnable(){ @Override publicvoidrun(){ System.out.println("===taskstart==="); try{ Thread.sleep(5000); }catch(InterruptedExceptione){ e.printStackTrace(); } System.out.println("===taskfinish==="); } }); thread.start(); System.out.println("main函数执行结束"); }

二、Future

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

@Test publicvoidtest1()throwsException{ System.out.println("main函数开始执行"); ExecutorServiceexecutor=Executors.newFixedThreadPool(1); Future<Integer>future=executor.submit(newCallable<Integer>(){ @Override publicIntegercall()throwsException{ System.out.println("===taskstart==="); Thread.sleep(5000); System.out.println("===taskfinish==="); return3; } }); //这里需要返回值时会阻塞主线程，如果不需要返回值使用是OK的。倒也还能接收 //Integerresult=future.get(); System.out.println("main函数执行结束"); System.in.read(); }

三、CompletableFuture

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

@Test publicvoidtest2()throwsException{ System.out.println("main函数开始执行"); ExecutorServiceexecutor=Executors.newFixedThreadPool(2); CompletableFuture<Integer>future=CompletableFuture.supplyAsync(newSupplier<Integer>(){ @Override publicIntegerget(){ System.out.println("===taskstart==="); try{ Thread.sleep(5000); }catch(InterruptedExceptione){ e.printStackTrace(); } System.out.println("===taskfinish==="); return3; } },executor); future.thenAccept(e->System.out.println(e)); System.out.println("main函数执行结束"); }

四、Spring的Async注解

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

xml方式：<task:annotation-driven/>

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

java方式：

@EnableAsync publicclassMyConfig{ @Bean publicTaskExecutorexecutor(){ ThreadPoolTaskExecutorexecutor=newThreadPoolTaskExecutor(); executor.setCorePoolSize(10);//核心线程数 executor.setMaxPoolSize(20);//最大线程数 executor.setQueueCapacity(1000);//队列大小 executor.setKeepAliveSeconds(300);//线程最大空闲时间 executor.setThreadNamePrefix("fsx-Executor-");//指定用于新创建的线程名称的前缀。 executor.setRejectedExecutionHandler(newThreadPoolExecutor.CallerRunsPolicy()); returnexecutor; } } （1）@Async @Test publicvoidtest3()throwsException{ System.out.println("main函数开始执行"); myService.longtime(); System.out.println("main函数执行结束"); } @Async publicvoidlongtime(){ System.out.println("我在执行一项耗时任务"); try{ Thread.sleep(5000); }catch(InterruptedExceptione){ e.printStackTrace(); } System.out.println("完成"); } （2）AsyncResult

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

@Test publicvoidtest4()throwsException{ System.out.println("main函数开始执行"); Future<Integer>future=myService.longtime2(); System.out.println("main函数执行结束"); System.out.println("异步执行结果："+future.get()); } @Async publicFuture<Integer>longtime2(){ System.out.println("我在执行一项耗时任务"); try{ Thread.sleep(8000); }catch(InterruptedExceptione){ e.printStackTrace(); } System.out.println("完成"); returnnewAsyncResult<>(3); }

本文内容总结：一、创建线程，二、Future，三、CompletableFuture，四、Spring的Async注解，，

原文链接：https://www.cnblogs.com/sword-successful/p/11181714.html