免费1级做看网站,快代理ip,视频网站如何推广,书法网站建站目标转载自 Java中的ThreadPoolExecutor类在前面的文章中#xff0c;我们使用线程的时候就去创建一个线程#xff0c;这样实现起来非常简便#xff0c;但是就会有一个问题#xff1a;
如果并发的线程数量很多#xff0c;并且每个线程都是执行一个时间很短的任务就结束了…转载自 Java中的ThreadPoolExecutor类在前面的文章中我们使用线程的时候就去创建一个线程这样实现起来非常简便但是就会有一个问题
如果并发的线程数量很多并且每个线程都是执行一个时间很短的任务就结束了这样频繁创建线程就会大大降低系统的效率因为频繁创建线程和销毁线程需要时间。
那么有没有一种办法使得线程可以复用就是执行完一个任务并不被销毁而是可以继续执行其他的任务
在Java中可以通过线程池来达到这样的效果。今天我们就来详细讲解一下Java的线程池首先我们从最核心的ThreadPoolExecutor类中的方法讲起然后再讲述它的实现原理接着给出了它的使用示例最后讨论了一下如何合理配置线程池的大小。
Java中的ThreadPoolExecutor类
java.uitl.concurrent.ThreadPoolExecutor类是线程池中最核心的一个类因此如果要透彻地了解Java中的线程池必须先了解这个类。下面我们来看一下ThreadPoolExecutor类的具体实现源码。
在ThreadPoolExecutor类中提供了四个构造方法
public class ThreadPoolExecutor extends AbstractExecutorService {public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueueRunnable workQueue);public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueueRunnable workQueue,ThreadFactory threadFactory);public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueueRunnable workQueue,RejectedExecutionHandler handler);public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueueRunnable workQueue,ThreadFactory threadFactory,RejectedExecutionHandler handler);
}
从上面的代码可以得知ThreadPoolExecutor继承了AbstractExecutorService类并提供了四个构造器事实上通过观察每个构造器的源码具体实现发现前面三个构造器都是调用的第四个构造器进行的初始化工作。
下面解释下一下构造器中各个参数的含义
corePoolSize核心池的大小这个参数跟后面讲述的线程池的实现原理有非常大的关系。在创建了线程池后默认情况下线程池中并没有任何线程而是等待有任务到来才创建线程去执行任务除非调用了prestartAllCoreThreads()或者prestartCoreThread()方法从这2个方法的名字就可以看出是预创建线程的意思即在没有任务到来之前就创建corePoolSize个线程或者一个线程。默认情况下在创建了线程池后线程池中的线程数为0当有任务来之后就会创建一个线程去执行任务当线程池中的线程数目达到corePoolSize后就会把到达的任务放到缓存队列当中maximumPoolSize线程池最大线程数这个参数也是一个非常重要的参数它表示在线程池中最多能创建多少个线程keepAliveTime表示线程没有任务执行时最多保持多久时间会终止。默认情况下只有当线程池中的线程数大于corePoolSize时keepAliveTime才会起作用直到线程池中的线程数不大于corePoolSize即当线程池中的线程数大于corePoolSize时如果一个线程空闲的时间达到keepAliveTime则会终止直到线程池中的线程数不超过corePoolSize。但是如果调用了allowCoreThreadTimeOut(boolean)方法在线程池中的线程数不大于corePoolSize时keepAliveTime参数也会起作用直到线程池中的线程数为0unit参数keepAliveTime的时间单位有7种取值在TimeUnit类中有7种静态属性NANOSECONDS, //纳秒
MICROSECONDS, //微妙
MILLISECONDS, //毫秒
SECONDS, //秒
MINUTES, //分钟
HOURS, //小时
DAYS; //天workQueue一个阻塞队列用来存储等待执行的任务这个参数的选择也很重要会对线程池的运行过程产生重大影响一般来说这里的阻塞队列有以下几种选择ArrayBlockingQueue
LinkedBlockingQueue;
PriorityBlockingQueue;
SynchronousQueue;
ArrayBlockingQueue和PriorityBlockingQueue使用较少一般使用LinkedBlockingQueue和Synchronous。线程池的排队策略与BlockingQueue有关。
threadFactory线程工厂主要用来创建线程handler表示当拒绝处理任务时的策略有以下四种取值
ThreadPoolExecutor.AbortPolicy:丢弃任务并抛出RejectedExecutionException异常。 ThreadPoolExecutor.DiscardPolicy也是丢弃任务但是不抛出异常。 ThreadPoolExecutor.DiscardOldestPolicy丢弃队列最前面的任务然后重新尝试执行任务重复此过程ThreadPoolExecutor.CallerRunsPolicy由调用线程处理该任务具体参数的配置与线程池的关系将在下一节讲述。
从上面给出的ThreadPoolExecutor类的代码可以知道ThreadPoolExecutor继承了AbstractExecutorService我们来看一下AbstractExecutorService的实现
public abstract class AbstractExecutorService implements ExecutorService {protected T RunnableFutureT newTaskFor(Runnable runnable, T value) { }protected T RunnableFutureT newTaskFor(CallableT callable) { }public Future? submit(Runnable task) {}public T FutureT submit(Runnable task, T result) {}public T FutureT submit(CallableT task) {}private T T doInvokeAny(Collection? extends CallableT tasks, boolean timed, long nanos)throws InterruptedException, ExecutionException, TimeoutException {}public T T invokeAny(Collection? extends CallableT tasks) throws InterruptedException, ExecutionException {}public T T invokeAny(Collection? extends CallableT tasks, long timeout, TimeUnit unit)throws InterruptedException, ExecutionException, TimeoutException {}public T ListFutureT invokeAll(Collection? extends CallableT tasks) throws InterruptedException {}public T ListFutureT invokeAll(Collection? extends CallableT tasks, long timeout, TimeUnit unit)throws InterruptedException {}
AbstractExecutorService是一个抽象类它实现了ExecutorService接口。
我们接着看ExecutorService接口的实现
public interface ExecutorService extends Executor {void shutdown();ListRunnable shutdownNow();boolean isShutdown();boolean isTerminated();boolean awaitTermination(long timeout, TimeUnit unit)throws InterruptedException;T FutureT submit(CallableT task);T FutureT submit(Runnable task, T result);Future? submit(Runnable task);T ListFutureT invokeAll(Collection? extends CallableT tasks)throws InterruptedException;T ListFutureT invokeAll(Collection? extends CallableT tasks,long timeout, TimeUnit unit)throws InterruptedException;T T invokeAny(Collection? extends CallableT tasks)throws InterruptedException, ExecutionException;T T invokeAny(Collection? extends CallableT tasks,long timeout, TimeUnit unit) throwsInterruptedException, ExecutionException, TimeoutException;
}
而ExecutorService又是继承了Executor接口我们看一下Executor接口的实现
public interface Executor {void execute(Runnable command);
}
到这里大家应该明白了ThreadPoolExecutor、AbstractExecutorService、ExecutorService和Executor几个之间的关系了。
Executor是一个顶层接口在它里面只声明了一个方法execute(Runnable)返回值为void参数为Runnable类型从字面意思可以理解就是用来执行传进去的任务的
然后ExecutorService接口继承了Executor接口并声明了一些方法submit、invokeAll、invokeAny以及shutDown等
抽象类AbstractExecutorService实现了ExecutorService接口基本实现了ExecutorService中声明的所有方法
然后ThreadPoolExecutor继承了类AbstractExecutorService。
在ThreadPoolExecutor类中有几个非常重要的方法
execute()submit()shutdown()shutdownNow()execute()方法实际上是Executor中声明的方法在ThreadPoolExecutor进行了具体的实现这个方法是ThreadPoolExecutor的核心方法通过这个方法可以向线程池提交一个任务交由线程池去执行。
submit()方法是在ExecutorService中声明的方法在AbstractExecutorService就已经有了具体的实现在ThreadPoolExecutor中并没有对其进行重写这个方法也是用来向线程池提交任务的但是它和execute()方法不同它能够返回任务执行的结果去看submit()方法的实现会发现它实际上还是调用的execute()方法只不过它利用了Future来获取任务执行结果Future相关内容将在下一篇讲述。
shutdown()和shutdownNow()是用来关闭线程池的。
还有很多其他的方法
比如getQueue() 、getPoolSize() 、getActiveCount()、getCompletedTaskCount()等获取与线程池相关属性的方法有兴趣的朋友可以自行查阅API。
