Java并发编程必备:ExecutorService、Future深入理解及实战应用

发布时间: 2024-09-30 11:35:33 阅读量: 16 订阅数: 26
![Java并发编程必备:ExecutorService、Future深入理解及实战应用](https://img-blog.csdnimg.cn/a0ea50d34dc746439fb51afd8a3908ca.png) # 1. Java并发编程与线程池基础 在现代的多核处理器和互联网时代,多线程编程已成为应用程序提高性能、响应用户请求的重要技术之一。Java作为一种广泛应用于企业级开发的语言,其内置的并发工具和线程池的使用是构建高效、稳定系统的关键。 Java并发编程允许开发者通过线程来实现任务的并行处理,而线程池的引入则是为了解决频繁创建和销毁线程所带来的性能损耗。线程池可以有效地复用线程,减少线程创建和销毁的开销,通过预分配和管理一组线程来执行多个任务,从而改善了程序的性能和资源利用率。 在本章中,我们将深入了解Java并发编程的基础,探讨线程池如何工作,并学习如何使用Java中的Executor框架来管理并发任务。我们会从线程池的基础概念出发,逐步揭示其背后的原理与实现,为深入掌握Java并发工具类打下坚实基础。 接下来,我们将详细探究线程池的各个方面,包括它的核心组件、生命周期管理、拒绝策略等,为后续章节中对线程池更高级应用的讨论做好铺垫。通过实例和详细解析,你将学会如何在Java应用中有效地使用线程池来处理并发任务。 # 2. ExecutorService的实现机制 ## 2.1 线程池的工作原理 ### 2.1.1 线程池核心组件分析 线程池是一种基于池化技术管理线程资源的并发工具,能够有效管理线程,减少资源消耗和提高系统响应速度。线程池的核心组件包括:线程池、工作线程、任务队列和拒绝策略。 - **线程池**: 线程池维护着一定数量的工作线程,通过管理这些工作线程来执行提交给它的任务。 - **工作线程**: 工作线程是线程池中的实际工作者,它们从任务队列中获取任务并执行。 - **任务队列**: 任务队列用于存放待执行的任务,线程池会根据自身的容量和队列情况将任务分发给工作线程。 - **拒绝策略**: 当线程池无法处理新提交的任务时,会执行拒绝策略,这通常根据不同的场景采取不同的策略。 #### 核心组件的相互作用 工作线程与任务队列的配合是线程池工作的基础。工作线程会不断从任务队列中取出任务并执行,直到任务队列为空。当新的任务提交到线程池时,如果任务队列未满,任务将被添加到队列中等待执行。若任务队列已满,工作线程数量未达上限,线程池则会创建新的工作线程来处理任务。如果工作线程数量已达到预设的最大值,且任务队列已满,则会触发拒绝策略。 ### 2.1.2 线程池的创建与配置 Java提供了`ThreadPoolExecutor`类来创建和配置线程池。创建线程池通常需要指定几个关键参数:核心线程数、最大线程数、任务队列、线程工厂、拒绝策略。 - **核心线程数**: 指定线程池保持活跃的最小工作线程数。 - **最大线程数**: 线程池可以创建的工作线程的最大数量。 - **任务队列**: 用于存放等待执行的任务。 - **线程工厂**: 用于创建新的线程。 - **拒绝策略**: 当线程池和任务队列均达到饱和时,采用的处理策略。 `ThreadPoolExecutor`构造函数的基本语法如下: ```java public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler) { // ... } ``` #### 示例代码 下面是一个简单的线程池创建与配置示例: ```java import java.util.concurrent.*; public class ThreadPoolExample { public static void main(String[] args) { BlockingQueue<Runnable> queue = new ArrayBlockingQueue<>(10); ThreadFactory factory = Executors.defaultThreadFactory(); RejectedExecutionHandler handler = new ThreadPoolExecutor.AbortPolicy(); ThreadPoolExecutor executor = new ThreadPoolExecutor( 5, // 核心线程数 10, // 最大线程数 30, // 空闲线程存活时间 TimeUnit.SECONDS, // 时间单位 queue, // 任务队列 factory, // 线程工厂 handler // 拒绝策略 ); // 执行任务 executor.execute(() -> System.out.println("任务执行中...")); // 关闭线程池 executor.shutdown(); } } ``` 在这个例子中,我们创建了一个拥有核心线程数为5,最大线程数为10的线程池。线程池使用的队列是最多存放10个任务的`ArrayBlockingQueue`。如果任务提交过多,达到10个且所有线程都处于忙碌状态时,提交的额外任务将会被拒绝,这里使用的拒绝策略是`AbortPolicy`,默认策略,会抛出`RejectedExecutionException`异常。 ### 2.2 ExecutorService的生命周期管理 #### 2.2.1 生命周期状态与转换 `ExecutorService`的生命周期管理是确保线程池稳定运行的关键。生命周期状态包括:运行(RUNNING)、关闭(SHUTDOWN)、停止(STOP)、整理(TIDYING)和终止(TERMINATED)。 - **RUNNING**: 可接受新任务且处理等待队列中的任务。 - **SHUTDOWN**: 不接受新任务,但处理等待队列中的任务。 - **STOP**: 不接受新任务,不处理等待队列中的任务,中断正在执行的任务。 - **TIDYING**: 所有任务已终止,`terminated()`方法将被调用。 - **TERMINATED**: 终止方法已经运行完成。 线程池从`RUNNING`到`TERMINATED`的过程中,状态转换是单向的。可以通过调用不同的方法来改变线程池的状态,如`shutdown()`和`shutdownNow()`。 #### 2.2.2 关闭策略与任务处理 关闭线程池时,合理的关闭策略和对等待任务的处理方式非常重要。`shutdown()`方法会停止接收新任务,同时继续处理队列中的现有任务。而`shutdownNow()`方法则会尝试停止所有正在执行的任务,并返回等待执行的任务列表。 在关闭线程池后,可以通过调用`isShutdown()`和`isTerminated()`来检查线程池是否停止和终止。通过等待`awaitTermination()`,可以设置超时时间,让调用者等待线程池完全终止。 ### 2.3 线程池的拒绝策略 #### 2.3.1 拒绝策略的类型与使用场景 拒绝策略是线程池用来处理无法执行的任务的一种机制。当线程池饱和时,将采用这些策略之一来决定如何拒绝新任务。Java的`ThreadPoolExecutor`类提供了以下几种内置的拒绝策略: - `AbortPolicy`: 默认策略,直接抛出异常,通知调用者任务无法执行。 - `CallerRunsPolicy`: 让提交任务的线程自己运行该任务。 - `DiscardPolicy`: 悄无声息地丢弃无法处理的任务。 - `DiscardOldestPolicy`: 丢弃队列中最老的任务,尝试为新任务腾出空间。 每种拒绝策略有其适用的场景,例如,如果任务提交者可以妥善处理异常,`AbortPolicy`可能是最佳选择;而`CallerRunsPolicy`可能适用于当任务量突然增大,但系统又不能拒绝这些任务的场景。 #### 2.3.2 自定义拒绝策略的实现 虽然Java提供了几种内置的拒绝策略,但在实际开发中,可能需要自定义拒绝策略以满足特定需求。自定义拒绝策略可以通过实现`RejectedExecutionHandler`接口来完成。在`rejectedExecution(Runnable r, ThreadPoolExecutor executor)`方法中定义你自己的拒绝逻辑。 下面是一个自定义拒绝策略的示例代码: ```java public class CustomRejectedHandler implements RejectedExecutionHandler { @Override public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) { // 例如:打印日志并抛出自定义异常 System.out.println("Task rejected: " + r.toString()); throw new CustomRejectedException("Task rejected by custom handler"); } public class CustomRejectedException extends Exception { public CustomRejectedException(String message) { super(message); } } } ``` 将自定义的拒绝策略传递给`ThreadPoolExecutor`的构造函数,就可以在达到拒绝条件时使用这个策略。 ## 2.3 线程池的拒绝策略 ### 2.3.1 拒绝策略的类型与使用场景 在处理线程池的饱和情况时,拒绝策略提供了不同的选择来处理无法执行的任务。以下四种内置拒绝策略是常见的选择: - `AbortPolicy`: 当线程池被关闭或已满时,抛出`RejectedExecutionException`异常。 - `CallerRunsPolicy`: 通过调用线程直接运行任务,从而防止任务队列无限膨胀。 - `DiscardPolicy`: 不执行任何操作,简单丢弃被拒绝的任务。 - `DiscardOldestPolicy`: 移除并抛弃队列中的头部任务,然后尝试重新提交被拒绝的任务。 拒绝策略的选择依据是具体的应用场景和业务需求,例如: - **AbortPolicy**: 当系统不能丢失任何任务时使用,必须尽快处理所有的提交任务。 - **CallerRunsPolicy**: 当任务的处理延迟是可以接受的时候使用,调用者可以控制任务执行的速度。 - **DiscardPolicy**: 当任务的重要性较低,可以被丢弃时使用。 - **DiscardOldestPolicy**: 当队列中待执行任务的可用性比新提交任务更高时使用。 ### 2.3.2 自定义拒绝策略的实现 如果内置的拒绝策略不能满足特定的应用需求,用户可以实现自定义拒绝策略,通过`RejectedExecutionHandler`接口实现。在`rejectedExecution(Runnable r, ThreadPoolExecutor executor)`方法中定义拒绝行为。 下面是一个自定义拒绝策略的实现示例: ```java import java.util.concurrent.*; public class MyRejectedExecutionHandler implements RejectedExecutionHandler { @Override public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) { // 自定义拒绝策略逻辑 System.out.println("Task rejected: " + r.toString()); // 可以根据实际情况记录日志、发送告警通知等 // 或者尝试将任务放入另一个线程池中 } } ``` 在创建`ThreadPoolExecutor`时,可以将自定义的拒绝策略作为参数传入: ```java ThreadPoolExecutor executor = new ThreadPoolExecutor( corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, threadFactory, new MyRejectedExecutionHandler() ); ``` 自定义拒绝策略为线程池提供了极高的灵活性,允许开发者根据业务需要进行高度定制化的处理。 # 3. ``` # 第三章:Future与Callable深入剖析 ## 3.1 Callable与Future接口概述 ### 3.1.1 Callable与Runnable的区别 Java中的Runnable接口是多线程编程中常用的一个接口,其`run`方法中不返回任何结果且不抛出异常。而Callable接口则有所不同,它在Java 5中引入,相比于Runnable,它允许任务执行后返回结果,并可以抛出受检异常。 从设计角度来说,Callable代表了那些可以抛出异常的任务,这使得任务的异常处理逻辑更加清晰。此外,Callable是泛型的,这意味着它可以返回任何类型的对象,这为任务的返回值提供了更大的灵活性。 例如,如果我们想要一个任务执行后返回一个整型结果,我们就可以定义一个Callable<Integer>。当调用Callable的`call`方法时,它将执行任务并返回一个结果,或者抛出异常。 ### 3.1.2 Future接口的作用与功能 Future接口是用于表示异步计算的结果的接口。当提交一个Callable任务到线程池时,你会得到一个Future对象。通过这个对象,你可以查询任务的执行状态,获取计算结果,或者取消任务的执行。 Future接口的主要功能包括: - `get()`:此方法等待任务完成,并返回任务的结果。如果任务尚未完成,这个调用会阻塞直到任务完成。 - `get(long timeout, TimeUnit unit)`:此方法具有超时特性,如果任务在指定的时间内完成,它将返回结果;否则,它将抛出一个TimeoutException。 - `cancel(boolean mayInterruptIfRunning)`:此方法尝试取消任务的执行。如果任务尚未启动,它将直接返回false;如果任务正在运行,它将根据参数决定是否中 ```
corwn 最低0.47元/天 解锁专栏
买1年送1年
点击查看下一篇
profit 百万级 高质量VIP文章无限畅学
profit 千万级 优质资源任意下载
profit C知道 免费提问 ( 生成式Al产品 )

相关推荐

SW_孙维

开发技术专家
知名科技公司工程师,开发技术领域拥有丰富的工作经验和专业知识。曾负责设计和开发多个复杂的软件系统,涉及到大规模数据处理、分布式系统和高性能计算等方面。
专栏简介
本专栏深入探讨了 Java 中广泛使用的第三方类库,涵盖性能优化、时间处理、数据序列化、IO 操作、并发编程、网络编程、加密解密、单元测试和 XML 处理等方面。通过对 Guava、Joda-Time、Jackson、NIO、ExecutorService、Netty、Bouncy Castle、JUnit、JDOM 和 C3P0 等知名类库的深入剖析和实用技巧,帮助 Java 开发者提升代码效率、简化开发流程,并掌握最佳实践。本专栏旨在为 Java 开发者提供全面的第三方类库指南,助力其构建高性能、可靠且可维护的应用程序。
最低0.47元/天 解锁专栏
买1年送1年
百万级 高质量VIP文章无限畅学
千万级 优质资源任意下载
C知道 免费提问 ( 生成式Al产品 )

最新推荐

【趋势分析】:MATLAB与艾伦方差在MEMS陀螺仪噪声分析中的最新应用

![【趋势分析】:MATLAB与艾伦方差在MEMS陀螺仪噪声分析中的最新应用](https://i0.hdslb.com/bfs/archive/9f0d63f1f071fa6e770e65a0e3cd3fac8acf8360.png@960w_540h_1c.webp) # 1. MEMS陀螺仪噪声分析基础 ## 1.1 噪声的定义和类型 在本章节,我们将对MEMS陀螺仪噪声进行初步探索。噪声可以被理解为任何影响测量精确度的信号变化,它是MEMS设备性能评估的核心问题之一。MEMS陀螺仪中常见的噪声类型包括白噪声、闪烁噪声和量化噪声等。理解这些噪声的来源和特点,对于提高设备性能至关重要。

【集成学习方法】:用MATLAB提高地基沉降预测的准确性

![【集成学习方法】:用MATLAB提高地基沉降预测的准确性](https://es.mathworks.com/discovery/feature-engineering/_jcr_content/mainParsys/image.adapt.full.medium.jpg/1644297717107.jpg) # 1. 集成学习方法概述 集成学习是一种机器学习范式,它通过构建并结合多个学习器来完成学习任务,旨在获得比单一学习器更好的预测性能。集成学习的核心在于组合策略,包括模型的多样性以及预测结果的平均或投票机制。在集成学习中,每个单独的模型被称为基学习器,而组合后的模型称为集成模型。该

【宠物管理系统权限管理】:基于角色的访问控制(RBAC)深度解析

![【宠物管理系统权限管理】:基于角色的访问控制(RBAC)深度解析](https://cyberhoot.com/wp-content/uploads/2021/02/5c195c704e91290a125e8c82_5b172236e17ccd3862bcf6b1_IAM20_RBAC-1024x568.jpeg) # 1. 基于角色的访问控制(RBAC)概述 在信息技术快速发展的今天,信息安全成为了企业和组织的核心关注点之一。在众多安全措施中,访问控制作为基础环节,保证了数据和系统资源的安全。基于角色的访问控制(Role-Based Access Control, RBAC)是一种广泛

脉冲宽度调制(PWM)在负载调制放大器中的应用:实例与技巧

![脉冲宽度调制(PWM)在负载调制放大器中的应用:实例与技巧](https://content.invisioncic.com/x284658/monthly_2019_07/image.thumb.png.bd7265693c567a01dd54836655e0beac.png) # 1. 脉冲宽度调制(PWM)基础与原理 脉冲宽度调制(PWM)是一种广泛应用于电子学和电力电子学的技术,它通过改变脉冲的宽度来调节负载上的平均电压或功率。PWM技术的核心在于脉冲信号的调制,这涉及到开关器件(如晶体管)的开启与关闭的时间比例,即占空比的调整。在占空比增加的情况下,负载上的平均电压或功率也会相

【Python分布式系统精讲】:理解CAP定理和一致性协议,让你在面试中无往不利

![【Python分布式系统精讲】:理解CAP定理和一致性协议,让你在面试中无往不利](https://ask.qcloudimg.com/http-save/yehe-4058312/247d00f710a6fc48d9c5774085d7e2bb.png) # 1. 分布式系统的基础概念 分布式系统是由多个独立的计算机组成,这些计算机通过网络连接在一起,并共同协作完成任务。在这样的系统中,不存在中心化的控制,而是由多个节点共同工作,每个节点可能运行不同的软件和硬件资源。分布式系统的设计目标通常包括可扩展性、容错性、弹性以及高性能。 分布式系统的难点之一是各个节点之间如何协调一致地工作。

MATLAB模块库翻译性能优化:关键点与策略分析

![MATLAB模块库翻译](https://img-blog.csdnimg.cn/b8f1a314e5e94d04b5e3a2379a136e17.png) # 1. MATLAB模块库性能优化概述 MATLAB作为强大的数学计算和仿真软件,广泛应用于工程计算、数据分析、算法开发等领域。然而,随着应用程序规模的不断增长,性能问题开始逐渐凸显。模块库的性能优化,不仅关乎代码的运行效率,也直接影响到用户的工作效率和软件的市场竞争力。本章旨在简要介绍MATLAB模块库性能优化的重要性,以及后续章节将深入探讨的优化方法和策略。 ## 1.1 MATLAB模块库性能优化的重要性 随着应用需求的

【数据不平衡环境下的应用】:CNN-BiLSTM的策略与技巧

![【数据不平衡环境下的应用】:CNN-BiLSTM的策略与技巧](https://www.blog.trainindata.com/wp-content/uploads/2023/03/undersampling-1024x576.png) # 1. 数据不平衡问题概述 数据不平衡是数据科学和机器学习中一个常见的问题,尤其是在分类任务中。不平衡数据集意味着不同类别在数据集中所占比例相差悬殊,这导致模型在预测时倾向于多数类,从而忽略了少数类的特征,进而降低了模型的泛化能力。 ## 1.1 数据不平衡的影响 当一个类别的样本数量远多于其他类别时,分类器可能会偏向于识别多数类,而对少数类的识别

【系统解耦与流量削峰技巧】:腾讯云Python SDK消息队列深度应用

![【系统解耦与流量削峰技巧】:腾讯云Python SDK消息队列深度应用](https://opengraph.githubassets.com/d1e4294ce6629a1f8611053070b930f47e0092aee640834ece7dacefab12dec8/Tencent-YouTu/Python_sdk) # 1. 系统解耦与流量削峰的基本概念 ## 1.1 系统解耦与流量削峰的必要性 在现代IT架构中,随着服务化和模块化的普及,系统间相互依赖关系越发复杂。系统解耦成为确保模块间低耦合、高内聚的关键技术。它不仅可以提升系统的可维护性,还可以增强系统的可用性和可扩展性。与

递归的单例模式实现:Java中的懒汉式与饿汉式技巧

![递归的单例模式实现:Java中的懒汉式与饿汉式技巧](https://xerostory.com/wp-content/uploads/2024/04/Singleton-Design-Pattern-1024x576.png) # 1. 单例模式的理论基础 单例模式(Singleton Pattern)是一种常用的软件设计模式,属于创建型模式。这种模式的主要目的是确保一个类只有一个实例,并提供一个全局访问点。单例模式的核心在于控制实例的创建过程,并确保全局只有一个访问点。 ## 单例模式的特点 单例模式主要有以下几个特点: 1. **全局只有一个实例**:这是单例模式最基本的特点

MATLAB机械手仿真并行计算:加速复杂仿真的实用技巧

![MATLAB机械手仿真并行计算:加速复杂仿真的实用技巧](https://img-blog.csdnimg.cn/direct/e10f8fe7496f429e9705642a79ea8c90.png) # 1. MATLAB机械手仿真基础 在这一章节中,我们将带领读者进入MATLAB机械手仿真的世界。为了使机械手仿真具有足够的实用性和可行性,我们将从基础开始,逐步深入到复杂的仿真技术中。 首先,我们将介绍机械手仿真的基本概念,包括仿真系统的构建、机械手的动力学模型以及如何使用MATLAB进行模型的参数化和控制。这将为后续章节中将要介绍的并行计算和仿真优化提供坚实的基础。 接下来,我
最低0.47元/天 解锁专栏
买1年送1年
百万级 高质量VIP文章无限畅学
千万级 优质资源任意下载
C知道 免费提问 ( 生成式Al产品 )