使用Thread或runnable接口都不能获取异步的执行结果#xff0c;因为他们没有返回值。

而通过实现Callable接口和Future就可以获取异步执行的结果#xff0c;当异步执行结束后…一、什么是Future

使用Thread或runnable接口都不能获取异步的执行结果因为他们没有返回值。

而通过实现Callable接口和Future就可以获取异步执行的结果当异步执行结束后返回结果将保存在Future中。

使用Future就可以让我们暂时去处理其他的任务而无需一直等待结果等异步任务执行完毕再返回其结果。

1、get方法

获取任务结束后返回的结果如果调用时任务还没有结束则会进行阻塞线程直到任务完成。

该阻塞是可以被打断的打断的线程是调用get方法的线程被打断后原任务会依旧继续执行。

get()

获取任务结束后返回的结果如果调用时任务还没有结束则会进行阻塞线程等待一定时间如果在规定时间内任务结束则返回结果否则抛出TimeoutException超时后任务依旧会继续执行。

该阻塞是可以被打断的打断的线程是调用get方法的线程被打断后原任务会依旧继续执行。

get(long

空闲线程是指当前线程池中超过了核心线程数之后多余的空闲线程的数量*/private

static

ThreadPoolExecutor(corePoolSize,maxPoolSize,keepAliveTime,TimeUnit.MILLISECONDS,new

LinkedBlockingQueue(blockingQueueSize),new

ThreadFactoryBuilder().setNameFormat(AsyncTaskThread

-%d).build(),new

ThreadPoolExecutor.CallerRunsPolicy());/***

异步任务执行**

{executorPool.execute(task);}/***

异步执行任务Callable,

executorPool.submit(task);}/***

param

executorPool.submit(task);}}步骤2编写测试类

Testpublic

{log.info(e.getMessage());}log.info([Future

Task]

completed...;});//执行其他任务log.info([Main

Thread]

running...);//使用future阻塞等待任务完成并获取结果String

futureResult

com.example.demo.dao.UserDaoTest

[Main

com.example.demo.dao.UserDaoTest

[Future

com.example.demo.dao.UserDaoTest

[Future

com.example.demo.dao.UserDaoTest

[Main

空闲线程是指当前线程池中超过了核心线程数之后多余的空闲线程的数量*/private

static

ThreadPoolExecutor(corePoolSize,maxPoolSize,keepAliveTime,TimeUnit.MILLISECONDS,new

LinkedBlockingQueue(blockingQueueSize),new

ThreadFactoryBuilder().setNameFormat(AsyncTaskThread

-%d).build(),new

ThreadPoolExecutor.CallerRunsPolicy());/***

创建一个ListeningExecutorService用于执行异步任务*

通过submit提交任务以ListenableFuture获取结果*/private

static

MoreExecutors.listeningDecorator(executorPool);/***

异步任务执行**

{executorPool.execute(task);}/***

异步执行任务Callable,

LISTENING_EXECUTOR.submit(task);}/***

param

LISTENING_EXECUTOR.submit(task);}

Testpublic

sqlSession.getMapper(UserDao.class);

boolean

mapper.getUserList().forEach(user

}//

AsyncTaskExecutor.execute(task);

log.info(main

over...);CompletableFutureSchool

schoolFuture

CompletableFuture();ListenableFutureSchool

listenableFuture1

{log.info(e.getMessage());}return

new

School(DSchool);});ListenableFutureSchool

listenableFuture2

{log.info(e.getMessage());}return

new

School(ESchool);});Futures.successfulAsList(listenableFuture1,

listenableFuture2).get();School

resSchool

TimeUnit.MILLISECONDS);log.info([Main

Thread]