图文并茂讲线程池
共 2540字,需浏览 6分钟
·
2022-06-10 04:13
基本组成
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
workQueue, //任务队列:维护着等待执行的Runnable对象 当所有的核心线程都在干活时,新添加的任务会被添加到这个队列中等待处理,如果队列满了,则新建非核心线程执行任务 ThreadFactory threadFactory, //创建新线程,Executors.defaultThreadFactory()
RejectedExecutionHandler handler) //线程池的饱和策略
通过ThreadPoolExecutor.execute(Runnable command)方法即可向线程池内添加一个任务
当一个任务被添加进线程池时:
1、线程数量未达到corePoolSize,则新建一个线程(核心线程)执行任务
2、线程数量达到了corePools,则将任务移入队列BlockingQueue等待
3、如果无法将任务加入BlockingQueue(队列已满),则在非corePool中创建新的线程来处理任务(注意,执行这一步骤需要获取全局锁)。
4、队列已满,总线程数又达到了maximumPoolSize,(RejectedExecutionHandler)抛出异常
四种java实现好的线程池
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);
}
}
线程池的状态
线程池风险:
死锁、资源不足、并发错误、 线程泄漏、请求过载
执行execute()方法和submit()方法的区别是什么呢?
execute() 方法用于提交不需要返回值的任务,所以无法判断任务是否被线程池执行成功与否;
submit()方法用于提交需要返回值的任务。线程池会返回一个future类型的对象,通过这个future对象可以判断任务是否执行成功,并且可以通过future的get()方法来获取返回值,get()方法会阻塞当前线程直到任务完成,而使用
get(long timeout,TimeUnit unit)
方法则会阻塞当前线程一段时间后立即返回,这时候有可能任务没有执行完。
source: //490.github.io/Java多线程与并发/
记得点「赞」和「在看」↓
爱你们