图文并茂讲线程池

JAVA乐园

共 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()方法的区别是什么呢?

  1. execute() 方法用于提交不需要返回值的任务,所以无法判断任务是否被线程池执行成功与否;

  2. submit()方法用于提交需要返回值的任务。线程池会返回一个future类型的对象,通过这个future对象可以判断任务是否执行成功,并且可以通过future的get()方法来获取返回值,get()方法会阻塞当前线程直到任务完成,而使用get(long timeout,TimeUnit unit) 方法则会阻塞当前线程一段时间后立即返回,这时候有可能任务没有执行完。

source: //490.github.io/Java多线程与并发/

记得点「」和「在看」↓

爱你们

浏览 49
点赞
评论
收藏
分享

手机扫一扫分享

分享
举报
评论
图片
表情
推荐
点赞
评论
收藏
分享

手机扫一扫分享

分享
举报