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

    xiaoxiao2021-03-25  15

    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方法,也可以在任务执行前、执行后和线程池关闭前执行一些代码进行监控。

                                           

    转载请注明原文地址: https://ju.6miu.com/read-300282.html

    最新回复(0)