线程池(关于变量捕获、线程数、针对ThreadPoolExecutor的构造方法参数的解释、自实现线程池)

news/2024/10/30 17:25:12/

目录:

一、前言

二、关于变量捕获

三、针对ThreadPoolExecutor的构造方法参数的解释

四、自实现线程池


一、前言

相比较于进程,创建线程 / 销毁线程 的开销是相对较小的,但是太过频繁的创建线程 / 销毁线程,其开销也很大。这时候我们就需要使用线程池来减少每次启动和销毁线程的损耗。事先把需要使用的线程先创建好,然后放到线程池中,后面需要使用的时候,直接从池里面获取,如果用完了就还给池。

二、关于变量捕获

 public static void main(String[] args) {ExecutorService pool = Executors.newFixedThreadPool(10);for (int i = 0; i < 1000; i++) {int n = i;pool.submit(new Runnable() {@Overridepublic void run() {//注意这里使用的是n,而不是iSystem.out.println("hello " + n);}});}}

这里for循环里面的变量 i 是主线程里的局部变量 (在主线程的栈上),随着主线程这里的代码块执行结束就销毁了,很可能主线程这里for执行完了,当前run的任务在线程池里还没排到,此时i就已经要销毁了。这里就是一个变量捕获,很明显,此处的run方法属于Runnable。这个方法的执行时机,不是立刻马上而是在未来的某个节点(后续在线程池的队列中,排到他了,就让对应的线程去执行)。为了避免作用域的差异,导致后续执行run的时候i已经销毁,于是就有了变量捕获,也就是让run方法把刚才主线程的i给往当前run的栈上拷贝一份。

三、针对ThreadPoolExecutor的构造方法参数的解释

API文档:https://docs.oracle.com/javase/8/docs/api/

  1. corePoolSize 核心线程数

  1. maximumPoolSize 最大线程数

ThreadPoolExecutor相当于把里面的线程分成两类:一类是正式员工(核心线程),一类是临时工(除核心线程外的线程),这两者之和就是最大线程数,核心线程理论上是可以摸鱼的,但是临时工不可以摸鱼,临时工摸鱼有时间限制,一旦超过了keepAliveTime规定的摸鱼时间,那么就会被销毁。

  1. keepAliveTime,unit 除核心线程外的线程数可以休息的时间(临时工可以摸鱼的最大时间)

  1. BlockingQueue<Runnable> workQueue 线程池的任务队列

  1. ThreadFactory threadFactory 线程工厂,用于创建线程

  1. RejectedExecutionHandler handler 描述了线程池的拒绝策略

拒绝策略1:ThreadPoolExecutor.AbortPolicy(如果任务队列满了,就直接抛出异常)

拒绝策略2:ThreadPoolExecutor.CallerRunsPolicy(如果队列满了,多出来的任务,是哪个线程加的,就由谁负责)

拒绝策略3:ThreadPoolExecutor.DiscardOldestPolicy(如果队列满了,就抛弃最早的任务,接受最新的任务)

拒绝策略4:ThreadPoolExecutor.DiscardPolicy(如果队列满了,就抛弃最新的任务)

四、自实现线程池

class MyThreadPoll{private BlockingQueue<Runnable> queue = new LinkedBlockingDeque<>();public MyThreadPoll(int n){//创建线程for (int i = 0; i < n; i++) {Thread t = new Thread(()->{while (true){try {Runnable runnable = queue.take();runnable.run();} catch (InterruptedException e) {e.printStackTrace();}}});t.start();}}//注册任务给线程池public void submit(Runnable runnable){try {queue.put(runnable);} catch (InterruptedException e) {e.printStackTrace();}}
}
public class ThreadDemo26 {public static void main(String[] args) {MyThreadPoll poll = new MyThreadPoll(10);for (int i = 0; i < 1000; i++) {int n = i;poll.submit(new Runnable() {@Overridepublic void run() {System.out.println("hello"+n);}});}}
}


http://www.ppmy.cn/news/12214.html

相关文章

JVM-【面试题】-垃圾收集算法+垃圾收集器,以后就不用担心对象那些事了

一、垃圾收集算法在jvm里对可回收的对象在不同的垃圾收集器里&#xff0c;有不同的回收算法&#xff0c;具体的可以分为这四种&#xff1a;分代收集算法、复制算法、标记清除算法、标记整理算法1.1 分代收集算法当前虚拟机的垃圾收集都采用分代收集算法&#xff0c;这种算法没有…

每日一问-ChapGPT-20230114-关于小年

文章目录每日一问-ChapGPT系列起因每日一问-ChapGPT-20230114-关于小年腊月每天都做些什么的歌谣为什么现在的年味淡了很多&#xff0c;感觉不到过年为什么春节放假要调休&#xff0c;不能多放几天吗说说现在世界上极端气候&#xff0c;以及多少年后&#xff0c;地球存在不适宜…

P3654 First Step (ファーストステップ)

P3654 First Step (ファーストステップ) 题目背景 知らないことばかりなにもかもが&#xff08;どうしたらいいの&#xff1f;&#xff09; 一切的一切 尽是充满了未知数&#xff08;该如何是好&#xff09; それでも期待で足が軽いよ&#xff08;ジャンプだ&#xff01;&…

如何避免内存溢出和频繁的垃圾回收

0 OOM和频繁GC预防方案 代码明明简单&#xff0c;日常跑没问题&#xff0c;怎么一大促就卡死甚至进程挂掉&#xff1f;大多因为设计时&#xff0c;就没针对高并发、高吞吐量case考虑过内存管理。 1 自动内存管理机制的实现原理 内存管理主要考虑&#xff1a; 1.1 申请内存 …

十九、命令模式 ( Command Pattern )

命令模式&#xff08;Command Pattern&#xff09;中请求以命令的形式包裹在对象中&#xff0c;并传给调用对象 调用对象寻找可以处理该命令的合适的对象&#xff0c;并把该命令传给相应的对象&#xff0c;该对象执行命令 命令模式是行为型模式&#xff0c;一种数据驱动的设计…

PCI、PCI-X、PCI-E、PCI-E Card、Mini PCI-E、M.2、Add-in Card 这些概念你搞清楚了吗

搞硬件或通信的“攻城狮”们&#xff0c;免不了要和各种通信协议及接口打交道。比如&#xff0c;我们经常接触PCI、PCI-X、PCI-E、PCI-E Card、Mini PCI-E、M.2(NGFF)、Add-in Card这些概念&#xff0c;作为“攻城狮”队伍中的一员&#xff0c;你搞清楚它们之间的关系了吗&…

JUC(java.util.concurrent)的常见类

文章目录一、JUC常见类Callable 接口ReentrantLockSemaphore(信号量)CountDownLatch一、JUC常见类 concurrent代表了并发&#xff0c;这个包下为我们提供了并发编程(多线程)相关的组件. Callable 接口 我们的Callable接口和Runnable是一样的&#xff0c;但也有一些区别: Run…

IIC通信协议

数据有效性 IC由两条线组成&#xff0c;一条双向串行数据线SDA&#xff0c;一条串行时钟线SCL。 SDA线上的数据必须在时钟的高电平周期保持稳定&#xff0c;数据线的高或低电平状态只有在 SCL 线的时钟信号是低电平时才能改变。 换言之&#xff0c; SCL为高电平时表示有效数据…