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策略:新提交的任务被抛弃。