一个线程的打工故事

简介: 一个线程的打工故事

我是谁

我是一个线程,一个底层的打工人。

网络异常,图片无法展示
|

总有人把我和进程搞混,但其实我和进程的区别很大。

进程是程序的一次执行,CPU的资源都是分发给进程而不是分发给我们线程,进程是资源分配的最小单位,一个进程可以包含很多向我这样的线程。

我们线程是CPU调度执行的最小单位,真正的打工人。

Java中的线程

在Java里面,我的名字叫做java.lang.Thread。

需要注意的是,调用run方法和执行一个普通方法没有区别。想要真正的创建一个线程并启动,需要调用我的start方法。

网络异常,图片无法展示
|

有一点我必须告诉你,就是我也是有小弟的。

在JVM里面,我有一个JavaThread的小弟,他帮我联系操作系统的osthread线程。

调用我的start方法之后,具体的执行流程是这样的:

网络异常,图片无法展示
|

当然了,这个过程省略了很多细节,不过很明确的是,我和内核线程是一一对应的。

调度我就相当于调度内核线程,而调度内核线程需要在用户态和内核态之间切换,这个过程开销是非常大的。

所以,创建我成本是很高的,一定要慎重。

网络异常,图片无法展示
|

线程池

和你们人类一样,我也有着精彩的一生,也会经历出生(创建)、奋斗(Running)、死亡(销毁)等过程,今天我主要和你讲述的是我打工奋斗的生活。

原来我是打零工的,有人需要我的时候就创建一个我,等我完成工作就把我销毁。

网络异常,图片无法展示
|

上面也提到过,我和内核线程是一对一的,创建和销毁的过程是非常消耗资源的,所以这样的成本非常高。

于是,有人就想了一个办法,开了一个公司,也就是你们说的线程池。

线程池公司统一管理调度我们线程。我们在线程池里面重复着等待工作——完成工作的步骤。

网络异常,图片无法展示
|

这样我就可以日复一日年复一年的重复打工了,这种提供了减少对象数量从而改善应用所需的对象结构的方式的模式,被你们人类叫做“享元模式”。

线程池公司有很多种,但都离不开这几个主要指标:

网络异常,图片无法展示
|

  • corePoolSize:公司正式员工人数。
  • maximumPoolSize:正式工+临时工最大数量。
  • keepAliveTime:临时工多久没做事情会被开除。
  • unit:临时工没做事情会被开除的时间单位。
  • workQueue:公司业务接收部门。
  • threadFactory:行政部,负责招聘培训员工的。
  • handler:业务部接收业务到达上限了的处理方式。

阻塞队列

线程池中的workQueue是一个阻塞队列,用于存放线程池未能及时处理执行的任务。

它的存在既解耦了任务的提交与执行,又能起到一个缓冲的作用。

阻塞队列有很多,下面我带你了解一下常见的阻塞队列。

ArrayBlockingQueue

基于数组实现的有界阻塞队列,创建的时候需要指定容量。此类型的队列按照FIFO(先进先出)的规则对元素进行排序。

网络异常,图片无法展示
|

LinkedBlockingQueue

基于链表实现阻塞队列,默认大小为Integer.MAX_VALUE。按照FIFO(先进先出)的规则对元素进行排序

网络异常,图片无法展示
|

SynchronousQueue

一个不存储元素的阻塞队列。每一个put操作必须阻塞等待其他线程的take操作,take操作也必须等待其他线程的put操作。

网络异常,图片无法展示
|

PriorityBlockingQueue

一个基于数组利用堆结构实现优先级效果的无界队列,默认自然序排序,也可以自己实现compareTo方法自定义排序规则。

网络异常,图片无法展示
|

DelayedWorkQueue

一个实现了优先级队列功能且实现了延迟获取的无界队列,在创建元素时,可以指定多久多久才能在队列中获取当前元素。只有延时期满了后才能从队列中获取元素。

网络异常,图片无法展示
|

拒绝策略

当任务队列满了之后,如果还有任务提交过来,会触发拒绝策略,常见的拒绝策略有:

  • AbortPolicy:丢弃任务并抛出异常,默认该方式。
  • CallerRunsPolicy:由调用线程自己处理该任务。谁调用,谁处理。

网络异常,图片无法展示
|

  • DiscardPolicy:丢弃任务,但是不抛出异常。
  • DiscardOldestPolicy:抛弃任务队列中最旧的任务也就是最先加入队列的,再把这个新任务添加进去。先从任务队列中弹出最先加入的任务,空出一个位置,然后再次执行execute方法把任务加入队列。

网络异常,图片无法展示
|

当然,除了以上这几种拒绝策略,你也可以根据实际的业务场景和业务需求去自定义拒绝策略,只需要实现RejectedExecutionHander接口,自定义里面的rejectedExecution方法。

运行流程

我们每个线程会被包装成Worker,线程池里面有一个HashSet存放Worker。

当有任务提交过来之后:

  1. 首先检测线程池运行状态,如果不是RUNNING,则直接拒绝,线程池要保证在RUNNING的状态下执行任务。
  2. 如果线程池中Worker的数量小于核心线程数,就会去创建一个新的线程,也就是招聘一个正式工让他执行任务。
  3. 如果Worker的数量大于或者等于核心线程数,就会把任务放到阻塞任务队列里面。
  4. 如果任务队列满了还有任务过来,如果临时工名额没有满(workerCount < maximumPoolSize),就去招聘临时工让临时工执行任务。如果临时工名额都满了,触发任务拒绝策略。

网络异常,图片无法展示
|

总结而言,就是核心线程能干的事情尽量不去创建非核心线程,这是线程池很关键的一点。

有哪些线程池

我有过四段工作经历,每段经历都有着精彩的故事。

SingleThreadExecutor

SingleThreadExecutor是我加入的第一家线程池,这是一家创业公司,整个线程池就只有我一个线程。

网络异常,图片无法展示
|

所有的任务都由我干,而且任务队列是一个无界队列。就是说,打工的线程只有我一个,但是需求任务可以是无限多。

在需求任务很多的时候,经常出现任务处理不过来的情况,导致任务堆积,出现OOM。

但因为所有的活都是我干,没有繁琐的沟通成本,不需要处理线程同步的问题,这算是这种线程池的一个优点吧。

这种线程池适用于并发量不大且需要任务顺序执行的场景。

FixedThreadPool

后来公司倒闭了,我又加入了一个叫FixedThreadPool的线程池。

网络异常,图片无法展示
|

FixedThreadPool和SingleThreadExecutor唯一不同的地方就是核心线程的数量,FixedThreadPool可以招收很多的打工线程。

在这里,我不再是孤军奋斗了,我有了一群共同打拼的小伙伴,大家一起完成任务,一起承担压力。

可这种线程池还是存在一个问题——任务队列是无界的,需求任务过多的话,还是会造成OOM。

这种线程池线程数固定,且不被回收,线程与线程池的生命周期同步的线程池,适用于任务量比较固定但耗时长的任务。

CachedThreadPool

后来,为了离家更近,我离职了。加入了一家叫CachedThreadPool的线程池,进去之后,却发现这是一家外包公司。

网络异常,图片无法展示
|

这种线程池里面没有一个核心线程(正式工),一有需求就去招聘一个非核心线程(临时工)。

如果一个线程任务干完了之后,60秒之后没有新的任务就会被辞退。

这种线程池的任务队列采用的是SynchronousQueue,这个队列是无法插入任务的,一有任务就创建一个线程执行,如果并发高且任务耗时长,创建太多线程也是可能导致OOM的。所以CachedThreadPool比较适合任务量大但耗时少的任务。

ScheduleThreadPool

经历了外面的风风雨雨,我觉得还是找份固定的工作比较可靠,于是我加入了一家叫做ScheduleThreadPool的国企。

网络异常,图片无法展示
|

在这里,工作比较的轻松,多数情况下,我只需要在固定的时间干固定的活。

任务忙不过来的时候,公司也会招聘一些临时工帮忙处理,临时工干完活就会被辞退。

综合来说,这类线程池适用于执行定时任务和具体固定周期的重复任务。由于采用的任务队列是DelayedWorkQueue无界队列,所以也是有OOM的风险的。

总结

好了,关于线程的故事就告一段落了。关于线程池的应用实践,我们下次再聊。

文章开头的面试题在大部分在文中都能找到答案,对于没有提到的,这里做一个补充:

1. 线程池提交任务有哪几种方式?分别有什么区别?

有execute和submit两种方式

  • execute只能提交Runnable类型的任务,无返回值。submit既可以提交Runnable类型的任务,也可以提交Callable类型的任务,会有一个类型为Future的返回值,但当任务类型为Runnable时,返回值为null。
  • execute在执行任务时,如果遇到异常会直接抛出,而submit不会直接抛出,只有在使用Future的get方法获取返回值时,才会抛出异常。

2. 线程池里面的线程执行异常了会怎么样?

如果一个线程执行任务的过程中出现异常,那么这个线程对应的Worker会被移出线程池,该线程也会被销毁回收。

同时会通过指定的线程工厂创建一个线程,并封装成Worker放入线程池代替移除的Worker。

网络异常,图片无法展示
|

3. 核心线程能被回收吗?

核心线程默认不会被回收。但是可以调用allowCoreThreadTimeOut让核心线程可以被回收。

网络异常,图片无法展示
|

需要注意的是,调用这个方法的线程池必须将keepAliveTime设置为大于0,否则会抛出异常。

网络异常,图片无法展示
|

4. 核心线程和非核心线程是如何区分的?

核心线程和非核心线程是一个抽象概念,只是用于更好的表述线程池的运行逻辑,实际上都对应操作系统的osThread,都是重量级线程。

在新增Worker的时候,通过一个boolean表达是核心线程还是非核心线程,本质上两者没有什么不同。

网络异常,图片无法展示
|

5. 为什么阿里不允许使用 Executors 去创建线程池?

FixedThreadPool 和 SingleThreadPool:允许的请求队列长度为 Integer.MAX_VALUE,可能会堆积大量的请求,从而导致 OOM。

CachedThreadPool:允许的创建线程数量为 Integer.MAX_VALUE,可能会创建大量的线程,从而导致 OOM。

总结来说就是,使用Executors创建线程池会容易忽视线程池的一些属性,使用不当容易引起资源耗尽。

写在最后

这个世界上或许没有线程,又或许人人都是线程。

好了,今天的文章就到这里了。

最后,感谢你的阅读!

我是CoderW,一个普通的程序员。

点个关注,我们下期再见!

参考文章

目录
相关文章
|
缓存 Java 数据处理
科大爱情故事之线程池工厂打工记
科大爱情故事之线程池工厂打工记
164 0
|
4月前
|
机器学习/深度学习 消息中间件 存储
【高薪程序员必看】万字长文拆解Java并发编程!(9-2):并发工具-线程池
🌟 ​大家好,我是摘星!​ 🌟今天为大家带来的是并发编程中的强力并发工具-线程池,废话不多说让我们直接开始。
188 0
|
10月前
|
Java 开发者
Java多线程编程中的常见误区与最佳实践####
本文深入剖析了Java多线程编程中开发者常遇到的几个典型误区,如对`start()`与`run()`方法的混淆使用、忽视线程安全问题、错误处理未同步的共享变量等,并针对这些问题提出了具体的解决方案和最佳实践。通过实例代码对比,直观展示了正确与错误的实现方式,旨在帮助读者构建更加健壮、高效的多线程应用程序。 ####
|
7月前
|
Linux
Linux编程: 在业务线程中注册和处理Linux信号
通过本文,您可以了解如何在业务线程中注册和处理Linux信号。正确处理信号可以提高程序的健壮性和稳定性。希望这些内容能帮助您更好地理解和应用Linux信号处理机制。
131 26
|
7月前
|
Linux
Linux编程: 在业务线程中注册和处理Linux信号
本文详细介绍了如何在Linux中通过在业务线程中注册和处理信号。我们讨论了信号的基本概念,并通过完整的代码示例展示了在业务线程中注册和处理信号的方法。通过正确地使用信号处理机制,可以提高程序的健壮性和响应能力。希望本文能帮助您更好地理解和应用Linux信号处理,提高开发效率和代码质量。
135 17
|
9月前
|
存储 安全 Java
Java多线程编程秘籍:各种方案一网打尽,不要错过!
Java 中实现多线程的方式主要有四种:继承 Thread 类、实现 Runnable 接口、实现 Callable 接口和使用线程池。每种方式各有优缺点,适用于不同的场景。继承 Thread 类最简单,实现 Runnable 接口更灵活,Callable 接口支持返回结果,线程池则便于管理和复用线程。实际应用中可根据需求选择合适的方式。此外,还介绍了多线程相关的常见面试问题及答案,涵盖线程概念、线程安全、线程池等知识点。
597 2
|
10月前
|
设计模式 Java 开发者
Java多线程编程的陷阱与解决方案####
本文深入探讨了Java多线程编程中常见的问题及其解决策略。通过分析竞态条件、死锁、活锁等典型场景,并结合代码示例和实用技巧,帮助开发者有效避免这些陷阱,提升并发程序的稳定性和性能。 ####
|
10月前
|
缓存 Java 开发者
Java多线程编程的陷阱与最佳实践####
本文深入探讨了Java多线程编程中常见的陷阱,如竞态条件、死锁和内存一致性错误,并提供了实用的避免策略。通过分析典型错误案例,本文旨在帮助开发者更好地理解和掌握多线程环境下的编程技巧,从而提升并发程序的稳定性和性能。 ####
|
9月前
|
缓存 Java 调度
多线程编程核心:上下文切换深度解析
在现代计算机系统中,多线程编程已成为提高程序性能和响应速度的关键技术。然而,多线程编程中一个不可避免的概念就是上下文切换(Context Switching)。本文将深入探讨上下文切换的概念、原因、影响以及优化策略,帮助你在工作和学习中深入理解这一技术干货。
236 10
|
10月前
|
安全 Java 开发者
Java中的多线程编程:从基础到实践
本文深入探讨了Java多线程编程的核心概念和实践技巧,旨在帮助读者理解多线程的工作原理,掌握线程的创建、管理和同步机制。通过具体示例和最佳实践,本文展示了如何在Java应用中有效地利用多线程技术,提高程序性能和响应速度。
215 11