Java中的线程池--读书笔记

1.《java并发编程的艺术》中对线程池的处理流程，解释如下：

1）线程池判断核心线程池里的线程是否都在执行任务。如果不是，则创建一个新的工作线程来执行任务。如果核心线程池里的线程都在执行任务，则进入下个流程。

2)  线程池判断工作对列是否已满。如果工作队列没有满，则将新提交的任务存储在这个工作队列里。如果工作队列满了，则进入下个流程。

3）线程池判断线程池的线程是否都处于工作状态。如果没有则创建一个新的工作线程来执行任务。如果已经满了，则交给饱和策略来处理该任务。

ThreadPoolExecutor执行executor（）方法的示意图：

           


ThreadPoolExecutor执行execute方法分以下4种情况。

1）如果当前运行的线程少于corePoolSize，则创建新线程来执行任务（注意，执行这一步骤需要获取全局锁）。

2）如果运行的线程等于或多余corePoolSize，则将任务加入BlockingQueue。

3）如果无法将任务加入BlockingQueue（队列已满），则创建新的线程来处理任务（注意，执行这一步骤需要获取全局锁）。

4）如果创建新线程将使当前运行的线程超出maximumPoolSize，任务将被拒绝，并调用RejectedExecutionHandler.rejectedExecution（）方法。

线程池创建线程时，会将线程封装成工作线程Worker，Worker在执行完任务后，还会循环获取工作队列里的任务来执行。

2.线程池的使用

new ThreadPoolExecutor（corePoolSize，maximumPoolSize，keepAliveTime，milliseconds，runnableTaskQueue，handler）；

1）corePoolSize:线程池的基本大小。当提交任务到线程池时，线程池会创建一个线程来执行任务，即使其他空闲的基本线程能够执行新任务也会创建线程，等到需要执行的任务数大于线程池基本大小时就不再创建。如果调用了线程池的prestartAllCoreThreads（）方法，线程池会提前创建并启动所有基本线程。

2）runnableTaskQueue（任务队列） 可选用：ArrayBlockingQueue，LinkedBlockingQueue，SynchronousQueue（不存储元素的阻塞队列），PriorityBlockingQueue。

3）RejectedExecutionHandler（饱和策略）。默认情况是AbortPolicy。

     Abortpolicy：直接抛出异常。

     CallerRunsPolicy：只用调用者所在线程来运行任务。

        DiscardOldestPolicy：丢弃队列里最近的一个任务，并执行当前任务。

    DiscardPolicy：不处理，丢弃掉。

3.execute（）方法用于提交不需要返回值的任务。

       submit（）方法用于提交需要返回值的任务。线程池会返回一个future类型的对象。

4.线程池的关闭：shutdown或shutDownNow。

     shutDown是将线程池的状态设置成shutdown状态，然后中断所有没有正在执行任务的线程。

     shutdownNow(不一定要将任务执行完)首先将线程池的状态设置为STOP，然后尝试停止所有的正在执行或暂停任务的线程，并返回等待执行任务的列表。

对于线程池的设定：CPU密集型任务应配置尽可能小的线程，如配置N（cpu）+1个线程。IO密集型任务，使用2*N（CPU）。混合任务建议进行拆分成一个CPU密集型的任务和一个IO密集型的任务。

对于使用优先级队列，如果一直有优先级高的任务提交到队列里，那么优先级低的任务可能永远不能执行。

可以通过Runtime.getRuntime（）.availableProcessors()方法获得当前设备的CPU个数。

建议使用有界队列。通过扩展线程进行监控。通过集成线程池来自定义线程池，重写线程池的beforeExecute/afterExecute和terminated方法，也可以在任务执行前、执行后和线程池关闭前执行一些代码进行监控。