java线程-线程池原理

1.如何创建线程池

//创建一个线程的线程池
        ExecutorService singleExecutor=Executors.newSingleThreadExecutor();
        //创建一个固定数量的线程池
        ExecutorService fixedExecutor=Executors.newFixedThreadPool(5);
        //创建一个线程池,线程最大数量为Integer.Max
        ExecutorService cachedExecutor=Executors.newCachedThreadPool();
        //创建线程池,可做定时调度
        ExecutorService scheduldExecutor=Executors.newScheduledThreadPool(500);

        //通过ThreadPoolExecutor创建线程
        new ThreadPoolExecutor();

2.线程池参数分析

public ThreadPoolExecutor(int corePoolSize,//核心线程书
                              int maximumPoolSize,//最大线程数
                              long keepAliveTime,//非核心线程数的存活时间
                              TimeUnit unit,//存活单位
                              BlockingQueue<Runnable> workQueue//阻塞队列) {
        this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue,
             Executors.defaultThreadFactory(), defaultHandler);
    }

3.线程池原理

          当提交一个新任务到线程池时首先线程池判断基本线程池(corePoolSize)是否已满?没满,创建一个工作线程来执行任务。满了,则进入下个流程;其次线程池判断工作队列(workQueue)是否已满?没满,则将新提交的任务存储在工作队列里。满了,则进入下个流程;最后线程池判断整个线程池(maximumPoolSize)是否已满?没满,则创建一个新的工作线程来执行任务,满了,则交给饱和策略来处理这个任务;如果线程池中的线程数量大于 corePoolSize 时,如果某线程空闲时间超过keepAliveTime,线程将被终止,直至线程池中的线程数目不大于corePoolSize;如果允许为核心池中的线程设置存活时间,那么核心池中的线程空闲时间超过 keepAliveTime,线程也会被终止。

饱和策略:

Abort策略:默认策略,新任务提交时直接抛出未检查的异常RejectedExecutionException,该异常可由调用者捕获。

CallerRuns策略:为调节机制,既不抛弃任务也不抛出异常,而是将某些任务回退到调用者。不会在线程池的线程中执行新的任务,而是在调用exector的线程中运行新的任务。

Discard策略:新提交的任务被抛弃。