JDK中的线程池和工作机制

初始化

线程池都是用ThreadPoolExecutor来初始化。

jdk预定义了一些线程池模板，可以用Executors来获取。

各个参数的含义

corePoolSize:线程池初始化时，核心线程数大小。

maximumPoolSize:线程池最大线程数。当核心线程用完了，队列里也装满了，会创建新的线程来执行任务，但不能超过最大线程数。

keepAliveTime:线程空闲下来后，线程的存活时间，只有线程数>corePoolSize时才有用。

unit:空闲时间的单位

workQueue:核心线程数满了后，装任务的队列。建议用有界队列，不然会有撑爆内存的风险。

threadFactory:线程工厂类，可以自定义线程的属性。

handler:拒接策略。

AbortPolicy ：直接抛出异常，默认； CallerRunsPolicy：用调用者所在的线程来执行任务 DiscardOldestPolicy：丢弃阻塞队列里最老的任务，队列里最靠前的任务 DiscardPolicy ：当前任务直接丢弃

实现自己的饱和策略，实现RejectedExecutionHandler接口即可

提交任务

execute()：不用返回值 submit(): 需要返回值

关闭线程池

shutdown(): 设置线程池状态，只有没有任务的线程会立即中断 shutdownNow():设置线程池状态，会尝试中断正在执行任务的线程

工作机制

public void execute(Runnable command) {
    if (command == null)
        throw new NullPointerException();

    int c = ctl.get();
    //当线程数小于corePoolSize时,会新建一个线程执行任务，并且自动新增workCount
    if (workerCountOf(c) < corePoolSize) {
        if (addWorker(command, true))
            return;
        c = ctl.get();
    }
    //当线程数大于corePoolSize时，会把任务缓存到workQueue
    if (isRunning(c) && workQueue.offer(command)) {
        int recheck = ctl.get();
        if (! isRunning(recheck) && remove(command))
            reject(command);
        else if (workerCountOf(recheck) == 0)
            addWorker(null, false);
    }
    //当线程数大于corePoolSize且workQueue也满了，线程数小于maximumPoolSize，会新建线程来执行任务
    else if (!addWorker(command, false))
        //任务的拒绝策略
        reject(command);
}

合理分配线程池

根据任务的性质来：计算密集型（CPU），IO密集型，混合型 计算密集型：加密，大数分解，正则…….，

线程数适当小一点，最大推荐：机器的Cpu核心数+1，为什么+1，防止页缺失，(机器的Cpu核心=Runtime.getRuntime().availableProcessors()?

IO密集型：读取文件，数据库连接，网络通讯, 线程数适当大一点，机器的Cpu核心数*2,

混合型：尽量拆分，IO密集型>>计算密集型，拆分意义不大，IO密集型~计算密集型

队列的选择上，应该使用有界，无界队列可能会导致内存溢出，OOM

预定义的线程池

FixedThreadPool 创建固定线程数量的，适用于负载较重的服务器，使用了无界队列 SingleThreadExecutor 创建单个线程，需要顺序保证执行任务，不会有多个线程活动，使用了无界队列

CachedThreadPool 会根据需要来创建新线程的，执行很多短期异步任务的程序，使用了SynchronousQueue

WorkStealingPool（JDK7以后） 基于ForkJoinPool实现

ScheduledThreadPoolExecutor 需要定期执行周期任务，Timer不建议使用了。

newSingleThreadScheduledExecutor：只包含一个线程，只需要单个线程执行周期任务，保证顺序的执行各个任务

newScheduledThreadPool 可以包含多个线程的，线程执行周期任务，适度控制后台线程数量的时候

方法说明： schedule：只执行一次，任务还可以延时执行 scheduleAtFixedRate：提交固定时间间隔的任务 scheduleWithFixedDelay：提交固定延时间隔执行的任务