广义上的完整线程池可能还包括Thread/Runnable、Timer/TimerTask等部分。这里只介绍主要的和高级的API和类。工具
此类是个工具类(工厂类),它提供对Executor、ExecutorService、ScheduledExecutorService、ThreadFactory 和 Callable 类的一些实用方法。spa
对ExecutorService类的初始化线程
ExecutorService newCachedThreadPool()htm
初始化0个线程,最大线程数为Integer.MAX_VALUEget
ExecutorService newCachedThreadPool(ThreadFactory threadFactory)it
初始化0个线程,最大线程数为Integer.MAX_VALUEio
ExecutorService newFixedThreadPool(int nThreads) :class
建立大小固定的线程执行者(初始化nThreads个线程,最大线程数为nThreads)thread
ExecutorService newFixedThreadPool(int nThreads, ThreadFactory threadFactory):配置
建立大小固定的线程执行者(初始化nThreads个线程,最大线程数为nThreads)
ExecutorService newSingleThreadExecutor():
建立一个线程执行者(初始化1个线程,最大线程数为1)
ExecutorService newSingleThreadExecutor(ThreadFactory threadFactory):
建立一个线程执行者(初始化1个线程,最大线程数为1)
ScheduledExecutorService newScheduledThreadPool(int corePoolSize)
建立一个调度任务线程执行者
ScheduledExecutorService newScheduledThreadPool(int corePoolSize, ThreadFactory threadFactory)
建立一个调度任务线程执行者
<T> Future<T> submit(Callable<T> task):
提交一个 Callable任务用于执行,并返回一个表示该任务的 Future。
Future<?> submit(Runnable task)
提交一个 Runnable任务用于执行,并返回一个表示该任务的 Future。
<T> Future<T> submit(Runnable task, T result)
提交一个 Runnable任务用于执行,并返回一个表示该任务的 Future。
<T> T invokeAny(Collection<? extends Callable<T>> tasks)
执行给定的任务,若是某个任务已成功完成(也就是未抛出异常),则返回其结果。一旦正常或异常返回后,则取消还没有完成的任务。若是此操做正在进行时修改了给定的集合,则此方法的结果是不明确的。
<T> T invokeAny(Collection<? extends Callable<T>> tasks,
long timeout, TimeUnit unit)
执行给定的任务,若是某个任务已成功完成(也就是未抛出异常),则返回其结果。一旦正常或异常返回后,则取消还没有完成的任务。若是此操做正在进行时修改了给定的集合,则此方法的结果是不明确的。(此方法执行全部任务,并返回第一个完成(未超时)且没有抛出异常的任务的结果)
<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
执行给定的任务,当全部任务完成时,返回保持任务状态和结果的 Future 列表。返回列表的全部元素的 Future.isDone() 为 true。注意,能够正常地或经过抛出异常来终止已完成 任务。若是正在进行此操做时修改了给定的集合,则此方法的结果是不明确的。
<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks,
long timeout, TimeUnit unit)
此方法执行全部任务,当它们所有完成且未超时,返回它们的执行结果。
此类是线程池类,
void execute(Runnable command)
void shutdown()
List<Runnable> shutdownNow()
boolean isTerminated():若是你已经调用shutdown()或shutdownNow()方法,而且执行者完成关闭它的处理时,此方法返回true。
boolean isShutdown():若是你在执行者中调用shutdown()方法,此方法返回true。
boolean awaitTermination(long timeout, TimeUnit unit):此方法阻塞调用线程,直到执行者的任务结束或超时
int getPoolSize():此方法返回线程池实际的线程数
int getActiveCount():此方法返回在执行者中正在执行任务的线程数
int getCompletedTaskCount():此方法返回执行者完成的任务数
int getLargestPoolSize():此方法,返回池中某一时刻最大的线程数
boolean awaitTermination(long timeout, TimeUnit unit)
等待线程执行完毕
给定的延迟后运行命令,或者按期执行命令。须要多个辅助线程时,或者要求 ThreadPoolExecutor 具备额外的灵活性或功能时,此类要优于 Timer。
ScheduledFuture<?> schedule(Runnable command,long delay,TimeUnit unit)
在给定的延迟后,建立和执行Runnabel。
ScheduledFuture<V> schedule(Callable<V> callable,long delay,TimeUnit unit)
在给定的延迟后,建立和执行Callable。
void setExecuteExistingDelayedTasksAfterShutdownPolicy(boolean value):
当你调用shutdown()方法时,而且有待处理的任务正在等待它们延迟结束。默认的行为是,无论执行者是否结束这些任务都将被执行,使用false,调用 shutdown()时,待处理的任务不会被执行。
ScheduledFuture<?> scheduleAtFixedRate(Runnable command,long initialDelay,long period,TimeUnit unit)
周期性的执行任务(你想要周期性执行的任务、第一次执行任务的延迟时间、两次执行之间的间隔期间、第二、3个参数的时间单位)
ScheduledFuture<?> scheduleWithFixedDelay(Runnable command,long initialDelay,long delay,TimeUnit unit)
在任务结束后固定的时间周期性执行任务(你想要周期性执行的任务、第一次执行任务的延迟时间、参数决定任务执行结束与下次执行开始之间的一段时间、第二、3个参数的时间单位)
void setContinueExistingPeriodicTasksAfterShutdownPolicy(boolean value)
当你使用 shutdown()方法时,你也能够经过参数配置一个SeduledThreadPoolExecutor的行为。shutdown()方法默认的行为是,当你调用这个方法时,计划任务就结束。 你能够使用ScheduledThreadPoolExecutor类的 setContinueExistingPeriodicTasksAfterShutdownPolicy()方法设置true值改变这个行为。在调用 shutdown()方法时,周期性任务将不会结束。