您当前的位置:首页 > 电脑百科 > 程序开发 > 语言 > JAVA

超简单,实现Java线程池

时间:2023-05-29 11:46:28  来源:  作者:Java学研大本营

1 问题描述

假设我们正在编写一个简单的应用程序,该应用程序从客户端接收一些输入,对其进行一些CPU密集型处理,然后记录输出。我们编写的代码看起来像以下内容:

class ProcessingLibrary {
 public void process (Input userInput) {
 // 一些CPU密集型逻辑,用于处理用户输入
 userInput.process();

 // 记录结果
 Logger.log(userInput.getResults());
 }
}

看起来很简单,一个普通的函数,它接受用户输入,对其进行一些处理,然后返回输出,我们可以将这个库提供给客户端。但是,你的客户如果正在高并发地调用该进程函数,很快他们可能会抱怨他们的请求处理输入的时间太长。原因非常简单,当外部客户端调用你的函数时,调用线程被阻塞,因为实际处理是由调用线程进行的。

2 初步解决方案

添加另一个要求:

  • 调用线程不应该被阻塞。

为了解决这个问题,我们可以考虑利用客户端的CPU核心并将多线程纳入我们的代码。我们进行一些修改,具体如下:

class ProcessingLibrary {
 public void process (Input userInput) {
 Runnable runnable = () -> {
 userInput.process();
 Logger.log(userInput.getResults());
 };

 Thread thread = new Thread(runnable);
 thread.start();
 }
}

对于每个请求,最好不要阻塞调用线程,而是生成一个新线程来进行重度处理。调用线程可以从我们的处理方法中提前返回。确实,这比我们早期的版本有很大的改进。我们的客户开始使用新版本,他们比以前更满意了。但现在他们开始抱怨CPU使用率变得过高,并且在他们那边发生了崩溃。发生了什么?如果我们仔细检查代码,我们会发现我们没有限制正在生成的线程数!如果客户以非常高的速率调用进程函数,可能会生成数百甚至数千个线程,这对CPU来说是很大的开销。我们还必须限制生成的线程数。

3 线程池

注意!我们这里又添加了一个要求:

  • 调用线程不应该被阻塞。

  • 我们的逻辑不应生成无限多数量的线程。

我们想要的是,调用线程不应该被阻塞,我们应该生成一定数量的线程,由客户根据他们的CPU资源和他们想要实现的并行度决定。实际数量取决于请求到达的速率和平均请求时间。线程池是解决这个问题的理想解决方案。线程池是一个简单的概念,可以并行执行应用程序代码并利用CPU核心。线程池包含一组固定数量的可重复使用的工作线程,它们执行分配给它们的任务,而不会阻塞调用线程。我们下面看看如何实现一个简单的线程池。

我们可以得出几个简单的观察:

  • 我们的线程应该是可重复使用的,并且应该在请求到达时惰性创建。线程创建是一个昂贵的过程(至少在JAVA中是这样)。

  • 如果请求到达的速率远高于线程池中的线程数,我们可以在其他请求执行完毕时将请求输入保持在等待状态,然后当一个线程完成处理一个请求时,它可以从请求行中获取另一个请求并开始处理它。通过这种方式,我们仍然可以实现相当高的并行性并获得更多的请求吞吐量。

  • 队列可以成为存储我们传入请求的良好数据结构,而我们的线程可以在完成先前的项目后不断地从队列中获取项目。

考虑以上要求,我们为线程池编写一个简单的类。

class ThreadPool {
 private BlockingQueue<Runnable> taskQueue;
 private Integer poolSize;
 private AtomicInteger currentPoolSize;

 public ThreadPool(int poolSize) {
 this.poolSize = poolSize;
 this.taskQueue = new LinkedBlockingQueue<>();
 this.currentPoolSize = new AtomicInteger(0);
 }
 
 public void submitTask(Runnable runnable) {
 this.taskQueue.add(runnable);
 
 if(this.currentPoolSize.get() < this.poolSize) {
 // 如果有更多的池大小可用,创建一个新线程
 // 这个线程也应该被重新用于未来任务
 // 因此,它应该继续从队列中寻找更多的任务
 
 this.currentPoolSize.incrementAndGet();
 this.createSingleThreadForPool();
 }
 }

 private void createSingleThreadForPool() {
 Runnable poolRunner = () -> {
 while(true) {
 if(this.taskQueue.size() > 0) {
 Runnable taskFromQueue = this.taskQueue.poll();
 taskFromQueue.run();
 }
 }
 };

 new Thread(poolRunner).start();
 }
}

从以上实现中可以得到以下几点:

  • BlockingQueue是一个线程安全的队列实现。我们需要确保线程安全,因为多个线程正在访问共享状态。AtomicInteger也是如此,用于线程安全更新我们当前的池大小。

  • 池运行者中的while循环是为了确保该线程保持活动状态,以便我们在想要接收更多任务时可以继续运行。

我们可以更改我们对ProcessingLibrary的实现,如下:

class ProcessingLibrary {
 private ThreadPool threadPool;
 
 public ProcessingLibrary(int poolSize) {
 this.threadPool = new ThreadPool(poolSize);
 }

 public void process (Input userInput) {
 Runnable runnable = () -> {
 userInput.process();
 Logger.log(userInput.getResults());
 };

 this.threadPool.submitTask(runnable);
 }
}

现在,我们已经满足了对这个问题的两个要求 :)

在Java中,concurrent库提供了与此类似的内容,称为ExecutorService。虽然我们讨论的实现有一些注意事项,例如我们生成的线程一直在等待,但这是一个理解线程池内部工作原理的良好起点。



Tags:Java线程池   点击:()  评论:()
声明:本站部分内容及图片来自互联网,转载是出于传递更多信息之目的,内容观点仅代表作者本人,不构成投资建议。投资者据此操作,风险自担。如有任何标注错误或版权侵犯请与我们联系,我们将及时更正、删除。
▌相关推荐
深入掌握Java线程池调度策略,优化任务执行
在Java开发中,线程池是一种重要的并发处理机制。合理地使用线程池可以提高系统性能、响应速度和资源利用率。下面将深入掌握Java线程池的调度策略,介绍线程池的原理和常用的调...【详细内容】
2023-12-29  Search: Java线程池  点击:(76)  评论:(0)  加入收藏
优雅的关闭Java线程池,这样做才是yyds
1 背景某年某月某日,和我的卧龙同事聊一个需求,说是有个数据查询的功能,因为涉及到多个第三方接口调用,想用线程池并行来做。很正常的一个方案,但是上线后发现,每次服务发布的时候...【详细内容】
2023-12-20  Search: Java线程池  点击:(125)  评论:(0)  加入收藏
Java线程池实现原理详解
1.池化背景在面向对象编程中,创建和销毁对象是很费时间的,因为创建一个对象要获取内存资源或者其它更多资源。在Java中更是如此,虚拟机将试图跟踪每一个对象,以便能够在对象销...【详细内容】
2023-07-06  Search: Java线程池  点击:(245)  评论:(0)  加入收藏
超简单,实现Java线程池
1 问题描述假设我们正在编写一个简单的应用程序,该应用程序从客户端接收一些输入,对其进行一些CPU密集型处理,然后记录输出。我们编写的代码看起来像以下内容:class ProcessingL...【详细内容】
2023-05-29  Search: Java线程池  点击:(129)  评论:(0)  加入收藏
编程中的Java线程池,你了解多少?
Java线程池是Java多线程编程中非常重要的概念,它可以有效地管理线程,提高程序的性能。本文将对Java线程池进行详细的介绍,包括线程池的概念、作用、实现原理以及常见的线程池使...【详细内容】
2023-02-24  Search: Java线程池  点击:(221)  评论:(0)  加入收藏
Java线程池
Java多线程的实现方式Java程序中,常见有4种方式实现多线程①继承Thread类②实现Runnable接口③实现Callable接口④使用Executor框架在JDK5之前,创建线程有2种方式,一种是继承Th...【详细内容】
2022-11-17  Search: Java线程池  点击:(294)  评论:(0)  加入收藏
如何优雅的关闭 Java线程池
简介 在开发中使用线程池去执行异步任务是比较普遍的操作,然而虽然有些异步操作我们并不十分要求可靠性和实时性,但总归业务还是需要的。如果在每次的服务发版过程中,我们不去...【详细内容】
2022-08-26  Search: Java线程池  点击:(454)  评论:(0)  加入收藏
彻底搞懂Java线程池的工作原理
多线程并发是Java语言中非常重要的一块内容,同时,也是Java基础的一个难点。说它重要是因为多线程是日常开发中频繁用到的知识,说它难是因为多线程并发涉及到的知识点非常之多,想...【详细内容】
2021-07-12  Search: Java线程池  点击:(361)  评论:(0)  加入收藏
Java线程池深度揭秘
作为 Java 程序员,无论是技术面试、项目研发或者是学习框架源码,不彻底掌握 Java 多线程的知识,做不到心中有数,干啥都没底气,尤其是技术深究时往往略显发憷。坐稳扶好,通过今天的...【详细内容】
2020-08-12  Search: Java线程池  点击:(274)  评论:(0)  加入收藏
Java线程池实现原理及其在美团业务中的实践
随着计算机行业的飞速发展,摩尔定律逐渐失效,多核CPU成为主流。使用多线程并行计算逐渐成为开发人员提升服务器性能的基本武器。J.U.C提供的线程池ThreadPoolExecutor类,帮助开...【详细内容】
2020-05-05  Search: Java线程池  点击:(247)  评论:(0)  加入收藏
▌简易百科推荐
Java 8 内存管理原理解析及内存故障排查实践
本文介绍Java8虚拟机的内存区域划分、内存垃圾回收工作原理解析、虚拟机内存分配配置,以及各垃圾收集器优缺点及场景应用、实践内存故障场景排查诊断,方便读者面临内存故障时...【详细内容】
2024-03-20  vivo互联网技术    Tags:Java 8   点击:(14)  评论:(0)  加入收藏
如何编写高性能的Java代码
作者 | 波哥审校 | 重楼在当今软件开发领域,编写高性能的Java代码是至关重要的。Java作为一种流行的编程语言,拥有强大的生态系统和丰富的工具链,但是要写出性能优异的Java代码...【详细内容】
2024-03-20    51CTO  Tags:Java代码   点击:(21)  评论:(0)  加入收藏
在Java应用程序中释放峰值性能:配置文件引导优化(PGO)概述
译者 | 李睿审校 | 重楼在Java开发领域,优化应用程序的性能是开发人员的持续追求。配置文件引导优化(Profile-Guided Optimization,PGO)是一种功能强大的技术,能够显著地提高Ja...【详细内容】
2024-03-18    51CTO  Tags:Java   点击:(24)  评论:(0)  加入收藏
Java生产环境下性能监控与调优详解
堆是 JVM 内存中最大的一块内存空间,该内存被所有线程共享,几乎所有对象和数组都被分配到了堆内存中。堆被划分为新生代和老年代,新生代又被进一步划分为 Eden 和 Survivor 区,...【详细内容】
2024-02-04  大雷家吃饭    Tags:Java   点击:(56)  评论:(0)  加入收藏
在项目中如何避免和解决Java内存泄漏问题
在Java中,内存泄漏通常指的是程序中存在一些不再使用的对象或数据结构仍然保持对内存的引用,从而导致这些对象无法被垃圾回收器回收,最终导致内存占用不断增加,进而影响程序的性...【详细内容】
2024-02-01  编程技术汇  今日头条  Tags:Java   点击:(68)  评论:(0)  加入收藏
Java中的缓存技术及其使用场景
Java中的缓存技术是一种优化手段,用于提高应用程序的性能和响应速度。缓存技术通过将计算结果或者经常访问的数据存储在快速访问的存储介质中,以便下次需要时可以更快地获取。...【详细内容】
2024-01-30  编程技术汇    Tags:Java   点击:(72)  评论:(0)  加入收藏
JDK17 与 JDK11 特性差异浅谈
从 JDK11 到 JDK17 ,Java 的发展经历了一系列重要的里程碑。其中最重要的是 JDK17 的发布,这是一个长期支持(LTS)版本,它将获得长期的更新和支持,有助于保持程序的稳定性和可靠性...【详细内容】
2024-01-26  政采云技术  51CTO  Tags:JDK17   点击:(88)  评论:(0)  加入收藏
Java并发编程高阶技术
随着计算机硬件的发展,多核处理器的普及和内存容量的增加,利用多线程实现异步并发成为提升程序性能的重要途径。在Java中,多线程的使用能够更好地发挥硬件资源,提高程序的响应...【详细内容】
2024-01-19  大雷家吃饭    Tags:Java   点击:(105)  评论:(0)  加入收藏
这篇文章彻底让你了解Java与RPA
前段时间更新系统的时候,发现多了一个名为Power Automate的应用,打开了解后发现是一个自动化应用,根据其描述,可以自动执行所有日常任务,说的还是比较夸张,简单用了下,对于office、...【详细内容】
2024-01-17  Java技术指北  微信公众号  Tags:Java   点击:(95)  评论:(0)  加入收藏
Java 在 2023 年仍然流行的 25 个原因
译者 | 刘汪洋审校 | 重楼学习 Java 的过程中,我意识到在 90 年代末 OOP 正值鼎盛时期,Java 作为能够真正实现这些概念的语言显得尤为突出(尽管我此前学过 C++,但相比 Java 影响...【详细内容】
2024-01-10  刘汪洋  51CTO  Tags:Java   点击:(74)  评论:(0)  加入收藏
站内最新
站内热门
站内头条