1、线程池管理器(ThreadPool):用于创建并管理线程池,包括 创建线程池,销毁线程池,添加新任务; 2、工作线程(PoolWorker):线程池中线程,在没有任务时处于等待状态,可以循环的执行任务; 3、任务接口(Task):每个任务必须实现的接口,以供工作线程调度任务的执行,它主要规定了任务的入口,任务执行完后的收尾工作,任务的执行状态等; 4、任务队列(taskQueue):用于存放没有处理的任务。提供一种缓冲机制。
java.uitl.concurrent.ThreadPoolExecutor类是线程池中最核心的一个类
构造参数
java.uitl.concurrent.ThreadPoolExecutor类是线程池中最核心的一个类
构造参数
public ThreadPoolExecutor(
int corePoolSize, //该线程池中核心线程数最大值。线程池新建线程的时候,如果当前线程总数小于corePoolSize,则新建的是核心线程,如果超过corePoolSize,则新建的是非核心线程 核心线程默认情况下会一直存活在线程池中,即使这个核心线程啥也不干(闲置状态)。如果指定ThreadPoolExecutor的allowCoreThreadTimeOut这个属性为true,那么核心线程如果不干活(闲置状态)的话,超过一定时间(时长下面参数决定),就会被销毁掉
int maximumPoolSize,//(线程不够用时能够创建的最大线程数)线程总数 = 核心线程数 + 非核心线程数
long keepAliveTime, //非核心线程闲置超时时长
TimeUnit unit, // keepAliveTime的单位,TimeUnit是一个枚举类型
BlockingQueue<Runnable> workQueue, //任务队列:维护着等待执行的Runnable对象 当所有的核心线程都在干活时,新添加的任务会被添加到这个队列中等待处理,如果队列满了,则新建非核心线程执行任务
ThreadFactory threadFactory, //创建新线程,Executors.defaultThreadFactory()
RejectedExecutionHandler handler) //线程池的饱和策略
通过ThreadPoolExecutor.execute(Runnable command)方法即可向线程池内添加一个任务
当一个任务被添加进线程池时:
1、线程数量未达到corePoolSize,则新建一个线程(核心线程)执行任务 2、线程数量达到了corePools,则将任务移入队列BlockingQueue等待 3、如果无法将任务加入BlockingQueue(队列已满),则在非corePool中创建新的线程来处理任务(注意,执行这一步骤需要获取全局锁)。 4、队列已满,总线程数又达到了maximumPoolSize,(RejectedExecutionHandler)抛出异常
CachedThreadPool()
可缓存线程池: 线程数无限制 有空闲线程则复用空闲线程,若无空闲线程则新建线程 一定程序减少频繁创建/销毁线程,减少系统开销
FixedThreadPool()
定长线程池: 可控制线程最大并发数(同时执行的线程数) 超出的线程会在队列中等待
ScheduledThreadPool()
定长线程池: 支持定时及周期性任务执行。
SingleThreadExecutor()
单线程化的线程池: 有且仅有一个工作线程执行任务 所有任务按照指定顺序执行,即遵循队列的入队出队规则
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class ThreadPoolExecutorTest {
public static void main(String[] args) {
ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(5);
scheduledThreadPool.schedule(new Runnable() {
public void run() {
System.out.println("delay 3 seconds");
}
}, 3, TimeUnit.SECONDS);
}
}
死锁、资源不足、并发错误、 线程泄漏、请求过载
get(long timeout,TimeUnit unit)
方法则会阻塞当前线程一段时间后立即返回,这时候有可能任务没有执行完。source: //490.github.io/Java多线程与并发/