ExecutorService扩展和实现Executor。
java 线程池的5种状态
RUNNING 线程池处在RUNNING状态时,能够接收新任务,以及对已添加的任务进行处理
SHUTDOWN 线程池处在SHUTDOWN状态时,不接收新任务,但能处理已添加的任务;调用线程池的shutdown()接口时,线程池由RUNNING -> SHUTDOWN
STOP 线程池处在STOP状态时,不接收新任务,不处理已添加的任务,并且会中断正在处理的任务;调用线程池的shutdownNow()接口时,线程池由(RUNNING or SHUTDOWN ) -> STOP
TIDYING 当所有的任务已终止,ctl记录的”任务数量”为0,线程池会变为TIDYING状态;当线程池在SHUTDOWN状态下,阻塞队列为空并且线程池中执行的任务也为空时,就会由 SHUTDOWN -> TIDYING。当线程池在STOP状态下,线程池中执行的任务为空时,就会由STOP -> TIDYING
TERMINATED 线程池彻底终止,就变成TERMINATED状态。 线程池处在TIDYING状态时,执行完terminated()之后,就会由 TIDYING -> TERMINATED
Java线程的6种状态及切换
初始(NEW):新创建了一个线程对象,但还没有调用start()方法。
运行(RUNNABLE):Java线程中将就绪(ready)和运行中(running)两种状态笼统的称为“运行”。线程对象创建后,其他线程(比如main线程)调用了该对象的start()方法。该状态的线程位于可运行线程池中,等待被线程调度选中,获取CPU的使用权,此时处于就绪状态(ready)。就绪状态的线程在获得CPU时间片后变为运行中状态(running)。
阻塞(BLOCKED):表示线程阻塞于锁。
等待(WAITING):进入该状态的线程需要等待其他线程做出一些特定动作(通知或中断)。
超时等待(TIMED_WAITING):该状态不同于WAITING,它可以在指定的时间后自行返回。
终止(TERMINATED):表示该线程已经执行完毕。
ExecutorService分析
public interface ExecutorService extends Executor{
//1 调用方法前提交的任务会执行
//2 调用方法后在提交任务会被拒绝
//3 ExecutorService已经关闭了 调用没有任何影响
//4 所有线程执行完当前的任务,ExecutorService才会真正关闭
//5 线程池的状态切换 SHUTDOWN
void shutdown();
//1 尝试停止所有正在执行的任务
//2 停止等待任务的处理
//3 返回等待执行的任务列表
//4 线程池状态设置STOP状态
//5 通过Thread的 interrupt方法停止执行的任务, 所以任何无法响应中断的任务都可能永远不会终止。
List<Runnable> shutdownNow();
//Returns true if this executor has been shut down
boolean isShutdown();
// return true if all tasks have completed following shut down.如果在调用这个方法之前,没有调用过shutdown 或shutdownNow,永远不会反悔true
boolean isTerminated();
//当前线程阻塞
//直到shutdown后等所有在执行的任务执行完
//等超时时间到
//或者线程被中断
boolean awaitTermination(long timeout, TimeUnit unit)
throws InterruptedException;
//Future get方法可以获得任务成功后的值
//如果想阻塞等待任务执行的结果,可以result = exec.submit(aCallable).get();
<T> Future<T> submit(Callable<T> task);
//任务成功后 get可以获取返回值
<T> Future<T> submit(Runnable task, T result);
// 任务成功后 get返回null
Future<?> submit(Runnable task);
//堵塞 等所有任务执行完成后统一返回
<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
throws InterruptedException;
//堵塞 等所有任务执行完成后统一返回, 设置超时时间 是所以任务一起的超时时间,超时会取消所有没有执行完的任务
<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks,
long timeout, TimeUnit unit)
throws InterruptedException;
//执行给定的任务,只要有一个任务成功执行完成,就返回结果。不包过异常。
// 正常返回和异常返回后,没有完成的任务将被取消
<T> T invokeAny(Collection<? extends Callable<T>> tasks)
throws InterruptedException, ExecutionException;
//同上 增加一个超时的时间
<T> T invokeAny(Collection<? extends Callable<T>> tasks,
long timeout, TimeUnit unit)
throws InterruptedException, ExecutionException, TimeoutException;
}