概述
juc包中引入了ExecutorService的概念,用来方便我们处理异步任务,不用直接创建Thread对象,并且能管理线程池,不用自己去创建线程,当一个任务执行完之后,这些池里的线程能够复用。JDK里的线程池对象都是实现了ExecutorService接口。
构建
JDK提供了Executors工具类能够让我们方便快捷的创建不同类型不同功能的ExecutorService实例,比如:
关闭
ExecutorService是不会自动关闭的,每当里面的任务被执行完之后,这些线程就会空出来等待新的任务到来。因此我们需要手动调用执行关闭方法。ExecutorService为我们提供了两种关闭的方法,showdown和showdownNow。这两个方法调用之后,isShutdown返回true,返回这个ExecutorService此时为关闭状态,而isTerminated方法不会马上返回true,只有当ExecutorService中的任务执行完了之后才会返回true。
- showdown,表示这个executor 为关闭状态,不再接收新任务,当执行中的任务都结束之后ExecutorService会自己关闭
- showdownNow,表示这个executor 为关闭状态,不再接收新任务,会想办法终止正在执行中的任务(一般是Thread.interupt()),但是只是想办法不能保证真的能终止
- awaitTermination,会阻塞一段时间,直到ExecutorService 终止,或者超时,或者当前线程被打断
showdown和showdownNow都会变成关闭状态,再接收任务会抛错。
关闭ExecutorService的示例
invokeAll 方法表示批量提交任务,并且返回future的list
带timeout参数的invokeAll 方法表示批量提交任务,在timeout时间内的任务会被执行完,超过时间的会被取消执行,如果使用future.get() 会报CancellationException 错误invokeAny 方法表示批量提交任务,并且返回最先执行结束的任务的结果,未执行完的任务会被取消
带timeout参数的invokeAny 方法表示批量提交任务,返回最先执行结束的任务的结果,未执行完的任务会被取消,如果在timeout时间内没有任务执行完,所有任务都会取消,返回null,并且抛错TimeoutException,最快的任务和timeout谁先到,谁先返回,如果最快的任务小于timeout则返回任务结果,如果timeout先到就抛TimeoutException,返回null