百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术教程 > 正文

Java线程池的四种用法与使用场景

mhr18 2024-12-06 16:55 13 浏览 0 评论

一、如下方式存在的问题

new Thread() {
 @Override
 public void run() {
 // 业务逻辑
 }
}.start();

1、首先频繁的创建、销毁对象是一个很消耗性能的事情;

2、如果用户量比较大,导致占用过多的资源,可能会导致我们的服务由于资源不足而宕机;

3、综上所述,在实际的开发中,这种操作其实是不可取的一种方式。

二、使用线程池有什么优点

1、线程池中线程的使用率提升,减少对象的创建、销毁;

2、线程池可以控制线程数,有效的提升服务器的使用资源,避免由于资源不足而发生宕机等问题;

三、线程池的四种使用方式

1、newCachedThreadPool

创建一个线程池,如果线程池中的线程数量过大,它可以有效的回收多余的线程,如果线程数不足,那么它可以创建新的线程。

public static void method() throws Exception {

 ExecutorService executor = Executors.newCachedThreadPool();

 for (int i = 0; i < 5; i++) {

 final int index = i;

 Thread.sleep(1000);

 executor.execute(new Runnable() {
 @Override
 public void run() {
 System.out.println(Thread.currentThread().getName() + " " + index);
 }
 });
 }
}

执行结果

通过分析我看可以看到,至始至终都由一个线程执行,实现了线程的复用,并没有创建多余的线程。

如果当我们的业务需要一定的时间进行处理,那么将会出现什么结果。我们来模拟一下。

可以明显的看出,现在就需要几条线程来交替执行。

不足:这种方式虽然可以根据业务场景自动的扩展线程数来处理我们的业务,但是最多需要多少个线程同时处理缺是我们无法控制的;

优点:如果当第二个任务开始,第一个任务已经执行结束,那么第二个任务会复用第一个任务创建的线程,并不会重新创建新的线程,提高了线程的复用率;

2、newFixedThreadPool

这种方式可以指定线程池中的线程数。举个栗子,如果一间澡堂子最大只能容纳20个人同时洗澡,那么后面来的人只能在外面排队等待。如果硬往里冲,那么只会出现一种情景,摩擦摩擦...

首先测试一下最大容量为一个线程,那么会不会是我们预测的结果。

public static void method_01() throws InterruptedException {

 ExecutorService executor = Executors.newFixedThreadPool(1);

 for (int i = 0; i < 10; i++) {

 Thread.sleep(1000);
 final int index = i;

 executor.execute(() -> {
 try {
 Thread.sleep(2 * 1000);
 } catch (InterruptedException e) {
 e.printStackTrace();
 }
 System.out.println(Thread.currentThread().getName() + " " + index);
 });
 }
 executor.shutdown();
}

执行结果

我们改为3条线程再来看下结果

优点:两个结果综合说明,newFixedThreadPool的线程数是可以进行控制的,因此我们可以通过控制最大线程来使我们的服务器打到最大的使用率,同事又可以保证及时流量突然增大也不会占用服务器过多的资源。

3、newScheduledThreadPool

该线程池支持定时,以及周期性的任务执行,我们可以延迟任务的执行时间,也可以设置一个周期性的时间让任务重复执行。 该线程池中有以下两种延迟的方法。

  • scheduleAtFixedRate

测试一

public static void method_02() {
 ScheduledExecutorService executor = Executors.newScheduledThreadPool(5);

 executor.scheduleAtFixedRate(new Runnable() {
 @Override
 public void run() {
 long start = new Date().getTime();
 System.out.println("scheduleAtFixedRate 开始执行时间:" +
 DateFormat.getTimeInstance().format(new Date()));
 try {
 Thread.sleep(5000);
 } catch (InterruptedException e) {
 e.printStackTrace();
 }
 long end = new Date().getTime();
 System.out.println("scheduleAtFixedRate 执行花费时间=" + (end - start) / 1000 + "m");
 System.out.println("scheduleAtFixedRate 执行完成时间:" + DateFormat.getTimeInstance().format(new Date()));
 System.out.println("======================================");
 }
 }, 1, 5, TimeUnit.SECONDS);
}

执行结果

测试二

总结:以上两种方式不同的地方是任务的执行时间,如果间隔时间大于任务的执行时间,任务不受执行时间的影响。如果间隔时间小于任务的执行时间,那么任务执行结束之后,会立马执行,至此间隔时间就会被打乱。

  • scheduleWithFixedDelay

测试一

public static void method_03() {
 ScheduledExecutorService executor = Executors.newScheduledThreadPool(2);

 executor.scheduleWithFixedDelay(new Runnable() {
 @Override
 public void run() {
 long start = new Date().getTime();
 System.out.println("scheduleWithFixedDelay 开始执行时间:" +
 DateFormat.getTimeInstance().format(new Date()));
 try {
 Thread.sleep(1000);
 } catch (InterruptedException e) {
 e.printStackTrace();
 }
 long end = new Date().getTime();
 System.out.println("scheduleWithFixedDelay执行花费时间=" + (end - start) / 1000 + "m");
 System.out.println("scheduleWithFixedDelay执行完成时间:"
 + DateFormat.getTimeInstance().format(new Date()));
 System.out.println("======================================");
 }
 }, 1, 2, TimeUnit.SECONDS);
}

执行结果

测试二

public static void method_03() {
 ScheduledExecutorService executor = Executors.newScheduledThreadPool(2);

 executor.scheduleWithFixedDelay(new Runnable() {
 @Override
 public void run() {
 long start = new Date().getTime();
 System.out.println("scheduleWithFixedDelay 开始执行时间:" +
 DateFormat.getTimeInstance().format(new Date()));
 try {
 Thread.sleep(5000);
 } catch (InterruptedException e) {
 e.printStackTrace();
 }
 long end = new Date().getTime();
 System.out.println("scheduleWithFixedDelay执行花费时间=" + (end - start) / 1000 + "m");
 System.out.println("scheduleWithFixedDelay执行完成时间:"
 + DateFormat.getTimeInstance().format(new Date()));
 System.out.println("======================================");
 }
 }, 1, 2, TimeUnit.SECONDS);
}

执行结果

总结:同样的,跟scheduleWithFixedDelay测试方法一样,可以测出scheduleWithFixedDelay的间隔时间不会受任务执行时间长短的影响。

4、newSingleThreadExecutor

这是一个单线程池,至始至终都由一个线程来执行。

public static void method_04() {

 ExecutorService executor = Executors.newSingleThreadExecutor();

 for (int i = 0; i < 5; i++) {
 final int index = i;
 executor.execute(() -> {
 try {
 Thread.sleep(2 * 1000);
 } catch (InterruptedException e) {
 e.printStackTrace();
 }
 System.out.println(Thread.currentThread().getName() + " " + index);
 });
 }
 executor.shutdown();
}

执行结果

四、线程池的作用

线程池的作用主要是为了提升系统的性能以及使用率。文章刚开始就提到,如果我们使用最简单的方式创建线程,如果用户量比较大,那么就会产生很多创建和销毁线程的动作,这会导致服务器在创建和销毁线程上消耗的性能可能要比处理实际业务花费的时间和性能更多。线程池就是为了解决这种这种问题而出现的。

同样思想的设计还有很多,比如数据库连接池,由于频繁的连接数据库,然而创建连接是一个很消耗性能的事情,所有数据库连接池就出现了。

五、读者福利

对于很多初级Java工程师而言,想要提升技能,往往是自己摸索成长,不成体系的学习效果低效漫长且无助。

整理的这些架构技术希望对Java开发的朋友们有所参考以及少走弯路,本文的重点是你有没有收获与成长,其余的都不重要,希望读者们能谨记这一点。同时我经过多年的收藏目前也算收集到了一套完整的学习资料,希望对想成为架构师的朋友有一定的参考和帮助。

下面是部分资料截图,诚意满满:特别适合有1-5年开发经验的Java程序员们学习。

资料免费领取方式:转发后,转发后关注我后台私信关键词【资料】获取!

而针对以上面试技术点,我在这里也做一些技术知识面试专题资料(包括Dubbo、Redis、Netty、zookeeper、Spring cloud、分布式、高并发等架构技术资料)免费分享,希望能更好的帮助到大家。

资料免费领取方式:转发后,转发后关注我后台私信关键词【资料】获取!

相关推荐

B站收藏视频失效?mybili 收藏夹备份神器完整部署指南

本内容来源于@什么值得买APP,观点仅代表作者本人|作者:羊刀仙很多B站用户都有过类似经历:自己精心收藏的视频突然“消失”,点开一看不是“已被删除”,就是“因UP主设置不可见”。而B站并不会主动通知...

中间件推荐初始化配置

Redis推荐初始化配置bind0.0.0.0protected-modeyesport6379tcp-backlog511timeout300tcp-keepalive300...

Redis中缓存穿透问题与解决方法

缓存穿透问题概述在Redis作为缓存使用时,缓存穿透是常见问题。正常查询流程是先从Redis缓存获取数据,若有则直接使用;若没有则去数据库查询,查到后存入缓存。但当请求的数据在缓存和数据库中都...

后端开发必看!Redis 哨兵机制如何保障系统高可用?

你是否曾在项目中遇到过Redis主服务器突然宕机,导致整个业务系统出现数据读取异常、响应延迟甚至服务中断的情况?面对这样的突发状况,作为互联网大厂的后端开发人员,如何快速恢复服务、保障系统的高可用...

Redis合集-大Key处理建议

以下是Redis大Key问题的全流程解决方案,涵盖检测、处理、优化及预防策略,结合代码示例和最佳实践:一、大Key的定义与风险1.大Key判定标准数据类型大Key阈值风险场景S...

深入解析跳跃表:Redis里的&quot;老六&quot;数据结构,专治各种不服

大家好,我是你们的码农段子手,今天要给大家讲一个Redis世界里最会"跳科目三"的数据结构——跳跃表(SkipList)。这货表面上是个青铜,实际上是个王者,连红黑树见了都要喊声大哥。...

Redis 中 AOF 持久化技术原理全解析,看完你就懂了!

你在使用Redis的过程中,有没有担心过数据丢失的问题?尤其是在服务器突然宕机、意外断电等情况发生时,那些还没来得及持久化的数据,是不是让你夜不能寐?别担心,Redis的AOF持久化技术就是...

Redis合集-必备的几款运维工具

Redis在应用Redis时,经常会面临的运维工作,包括Redis的运行状态监控,数据迁移,主从集群、切片集群的部署和运维。接下来,从这三个方面,介绍一些工具。先来学习下监控Redis实时...

别再纠结线程池大小 + 线程数量了,没有固定公式的!

我们在百度上能很轻易地搜索到以下线程池设置大小的理论:在一台服务器上我们按照以下设置CPU密集型的程序-核心数+1I/O密集型的程序-核心数*2你不会真的按照这个理论来设置线程池的...

网络编程—IO多路复用详解

假如你想了解IO多路复用,那本文或许可以帮助你本文的最大目的就是想要把select、epoll在执行过程中干了什么叙述出来,所以具体的代码不会涉及,毕竟不同语言的接口有所区别。基础知识IO多路复用涉及...

5分钟学会C/C++多线程编程进程和线程

前言对线程有基本的理解简单的C++面向过程编程能力创造单个简单的线程。创造单个带参数的线程。如何等待线程结束。创造多个线程,并使用互斥量来防止资源抢占。会使用之后,直接跳到“汇总”,复制模板来用就行...

尽情阅读,技术进阶,详解mmap的原理

1.一句话概括mmapmmap的作用,在应用这一层,是让你把文件的某一段,当作内存一样来访问。将文件映射到物理内存,将进程虚拟空间映射到那块内存。这样,进程不仅能像访问内存一样读写文件,多个进程...

C++11多线程知识点总结

一、多线程的基本概念1、进程与线程的区别和联系进程:进程是一个动态的过程,是一个活动的实体。简单来说,一个应用程序的运行就可以被看做是一个进程;线程:是运行中的实际的任务执行者。可以说,进程中包含了多...

微服务高可用的2个关键技巧,你一定用得上

概述上一篇文章讲了一个朋友公司使用SpringCloud架构遇到问题的一个真实案例,虽然不是什么大的技术问题,但如果对一些东西理解的不深刻,还真会犯一些错误。这篇文章我们来聊聊在微服务架构中,到底如...

Java线程间如何共享与传递数据

1、背景在日常SpringBoot应用或者Java应用开发中,使用多线程编程有很多好处,比如可以同时处理多个任务,提高程序的并发性;可以充分利用计算机的多核处理器,使得程序能够更好地利用计算机的资源,...

取消回复欢迎 发表评论: