Java中的线程池（附有代码示例）

2024-02-11 00:44
文章标签 java 代码 线程 示例 附有

本文主要是介绍Java中的线程池（附有代码示例），希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

目录

一、Java线程池介绍

二、几种常见的线程池

2.1 FixedThreadPool

2.2 CachedThreadPool

2.3 ScheduledThreadPool

2.4 SingleThreadPool

2.5 WorkStealingPool

三、线程池的运用场景

3.1 FixedThreadPool（固定大小线程池）

3.2 CachedThreadPool（缓存线程池）

3.3 ScheduledThreadPool（定时任务线程池）

3.4 SingleThreadPool（单线程线程池）

3.5 WorkStealingPool（工作窃取线程池）

四、线程池创建时的核心参数

4.1 corePoolSize（核心线程数）

4.2 maximumPoolSize（最大线程数）

4.3 keepAliveTime（线程空闲时间）

4.4 unit（线程空闲时间单位）

4.5 workQueue（工作队列）

4.6 threadFactory（线程工厂）

4.7 handler（拒绝策略）

一、Java线程池介绍

在Java中，线程池是一种管理和复用线程的机制，用于提高多线程应用程序的性能和资源利用率。线程池在执行任务时，可以避免频繁地创建和销毁线程，从而减少了系统开销，并且能够更有效地利用系统资源。Java中线程池的主要作用包括以下方面：

① 线程的复用：线程池会预先创建一定数量的线程，并将它们保存在池中。当有任务需要执行时，线程池会分配一个空闲的线程来执行任务，执行完毕后线程不会销毁，而是重新放入线程池中，等待下一个任务的到来。这种线程的复用避免了频繁地创建和销毁线程，提高了线程的利用率。

② 资源管理：线程池可以限制并发线程的数量，避免系统因为线程过多而导致资源耗尽或性能下降的问题。通过配置线程池的核心参数，可以控制线程数量的上限、空闲线程的存活时间等，从而更好地管理系统资源。

③ 任务调度：线程池可以用于执行各种类型的任务，包括周期性任务、延迟任务、定时任务等。通过使用不同类型的线程池和调度策略，可以灵活地调度任务的执行时间和执行方式，满足不同场景下的需求。

Java中线程池的实现主要依赖于java.util.concurrent包下的Executor接口及其子接口ExecutorService，以及ThreadPoolExecutor等具体实现类。开发人员可以通过这些接口和类来创建和管理线程池，并通过配置不同的参数来满足不同的需求。

二、几种常见的线程池

2.1 FixedThreadPool

FixedThreadPool（固定大小线程池）：该线程池会一直保持在核心线程数的数量不变，即使有空闲线程。当有新任务提交时，如果所有核心线程都在执行任务，新任务会被放入队列中等待。这种线程池适用于负载较重的服务器。

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class FixedThreadPoolExample {public static void main(String[] args) {// 创建一个固定大小为3的线程池ExecutorService executor = Executors.newFixedThreadPool(3);for (int i = 0; i < 10; i++) {final int taskId = i;executor.execute(() -> {System.out.println("Task " + taskId + " is executing by " + Thread.currentThread().getName());try {Thread.sleep(2000); // 模拟任务执行时间} catch (InterruptedException e) {e.printStackTrace();}System.out.println("Task " + taskId + " completed.");});}executor.shutdown();}
}

2.2 CachedThreadPool

CachedThreadPool（缓存线程池）：该线程池会根据需要自动创建新线程，但在一定的时间范围内会重用之前创建的线程。如果线程长时间空闲，它会被回收，从而减少系统资源的占用。适用于执行大量短期异步任务的情况。

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class CachedThreadPoolExample {public static void main(String[] args) {// 创建一个可缓存线程池ExecutorService executor = Executors.newCachedThreadPool();for (int i = 0; i < 10; i++) {final int taskId = i;executor.execute(() -> {System.out.println("Task " + taskId + " is executing by " + Thread.currentThread().getName());try {Thread.sleep(2000); // 模拟任务执行时间} catch (InterruptedException e) {e.printStackTrace();}System.out.println("Task " + taskId + " completed.");});}executor.shutdown();}
}
2.3 ScheduledThreadPool

ScheduledThreadPool（定时任务线程池）：该线程池可用于执行定时任务和周期性任务。它可以指定核心线程数，当任务执行时间超过线程池核心线程数时，会创建新线程来处理。

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;public class ScheduledThreadPoolExample {public static void main(String[] args) {// 创建一个定时任务线程池ScheduledExecutorService executor = Executors.newScheduledThreadPool(3);executor.scheduleAtFixedRate(() -> {System.out.println("Task executing by " + Thread.currentThread().getName());}, 0, 3, TimeUnit.SECONDS); // 初始延迟0秒，每3秒执行一次任务}
}

2.4 SingleThreadPool

SingleThreadPool（单线程线程池）：该线程池只有一个核心线程，所有任务按照指定顺序执行，即保证了任务的顺序性。如果该线程异常结束，会重新创建一个新的线程来替代。适用于需要顺序执行任务且保证线程安全的情况。

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class SingleThreadPoolExample {public static void main(String[] args) {// 创建一个单线程线程池ExecutorService executor = Executors.newSingleThreadExecutor();for (int i = 0; i < 5; i++) {final int taskId = i;executor.execute(() -> {System.out.println("Task " + taskId + " is executing by " + Thread.currentThread().getName());try {Thread.sleep(2000); // 模拟任务执行时间} catch (InterruptedException e) {e.printStackTrace();}System.out.println("Task " + taskId + " completed.");});}executor.shutdown();}
}
2.5 WorkStealingPool

WorkStealingPool（工作窃取线程池）：Java 8引入了这种新型线程池，它的核心思想是让空闲的线程从其他任务队列中窃取任务来执行，以提高线程利用率。这种线程池适用于处理大量耗时较长的任务。

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;public class WorkStealingPoolExample {public static void main(String[] args) throws InterruptedException {// 获取当前系统的处理器数量作为线程池大小int processors = Runtime.getRuntime().availableProcessors();// 创建工作窃取线程池ExecutorService executor = Executors.newWorkStealingPool(processors);for (int i = 0; i < 10; i++) {final int taskId = i;executor.execute(() -> {System.out.println("Task " + taskId + " is executing by " + Thread.currentThread().getName());try {Thread.sleep(2000); // 模拟任务执行时间} catch (InterruptedException e) {e.printStackTrace();}System.out.println("Task " + taskId + " completed.");});}executor.awaitTermination(10, TimeUnit.SECONDS);executor.shutdown();}
}

三、线程池的运用场景

3.1 FixedThreadPool（固定大小线程池）
  • 运用场景：适用于需要控制并发线程数量的场景，如服务器端的并发处理任务。比如，处理客户端请求的 Web 服务器，通常会预先分配一定数量的线程用于处理请求，以避免过多的线程导致资源竞争或资源耗尽。
  • 优势：固定大小线程池可以保证同时执行的线程数量是有限的，避免了因为线程数量过多而导致的资源竞争和系统资源的浪费。

3.2 CachedThreadPool（缓存线程池）
  • 运用场景：适用于需要处理大量短期异步任务的场景，任务执行时间短且任务数量不确定的情况。比如，处理用户请求的 Web 服务器，用户的请求可能会随时增加或减少，使用缓存线程池可以根据需求动态调整线程数量，避免了创建过多的线程而浪费系统资源。
  • 优势：能够根据需求动态调整线程池的大小，灵活性较高，适应性强。

3.3 ScheduledThreadPool（定时任务线程池）
  • 运用场景：适用于需要执行定时任务或周期性任务的场景。比如，定时数据备份、定时任务调度等。此外，也适用于需要同时处理多个延迟任务的情况。
  • 优势：能够按照预定的时间间隔或延迟执行任务，方便管理和调度。
3.4 SingleThreadPool（单线程线程池）
  • 运用场景：适用于需要保证任务的顺序执行和线程安全的场景。比如，文件操作、数据库操作等需要顺序执行的任务。
  • 优势：保证任务按顺序执行，避免了多线程情况下可能出现的竞争和同步问题。

3.5 WorkStealingPool（工作窃取线程池）
  • 运用场景：适用于需要处理大量耗时较长的任务的情况，任务之间可能存在依赖关系，需要充分利用系统资源来提高并行度和性能。
  • 优势：能够动态地在多个任务队列之间进行工作窃取，提高了线程的利用率，同时能够更好地利用多核处理器的并行计算能力。

四、线程池创建时的核心参数

4.1 corePoolSize（核心线程数）
  • 含义：线程池中保持活跃的核心线程数量，即使这些线程当前没有执行任务。
  • 默认值：通常情况下，线程池在没有接收到任务时不会创建任何线程。但是，如果你希望线程池在创建时就立即创建一定数量的线程，则可以设置该参数，使得线程池在空闲时也能保持一定数量的核心线程。
4.2 maximumPoolSize（最大线程数）
  • 含义：线程池允许创建的最大线程数。
  • 默认值：通常情况下，线程池在达到核心线程数后，如果继续有新的任务提交，它会创建新的线程来执行任务，直到线程数量达到最大线程数。超过最大线程数的任务会被拒绝执行。
4.3 keepAliveTime（线程空闲时间）
  • 含义：当线程池中的线程数量超过核心线程数时，多余的空闲线程在终止之前等待新任务的最长时间。
  • 默认值：默认情况下，只有当线程池中的线程数量超过核心线程数时，才会考虑终止空闲线程。该参数指定了空闲线程的最长等待时间。超过这个时间后，多余的空闲线程将被终止，直到线程数量不超过核心线程数。
4.4 unit（线程空闲时间单位）
  • 含义：线程空闲时间的单位，通常与keepAliveTime一起使用。
  • 默认值：常见的单位包括TimeUnit.MILLISECONDS（毫秒）、TimeUnit.SECONDS（秒）等。
4.5 workQueue（工作队列）
  • 含义：用于保存等待执行的任务的阻塞队列。
  • 默认值：Java提供了多种实现，如LinkedBlockingQueue、ArrayBlockingQueue等。具体选择哪种队列取决于你的需求和场景。一般情况下，如果任务频繁产生而执行较慢时，推荐使用无界队列；如果任务产生的速度大于处理的速度，可以考虑使用有界队列，以避免无限制的任务增长。
4.6 threadFactory（线程工厂）
  • 含义：用于创建新线程的工厂类。
  • 默认值：如果不显式指定线程工厂，线程池会使用默认的线程工厂来创建线程。你可以通过实现ThreadFactory接口来自定义线程创建的过程，比如设置线程的名称、优先级等信息。
4.7 handler（拒绝策略）
  • 含义：当工作队列已满且无法继续接收新任务时，线程池会采取的策略。
  • 默认值：Java提供了多种拒绝策略，如AbortPolicy（默认策略，直接抛出RejectedExecutionException异常）、CallerRunsPolicy（由提交任务的线程执行被拒绝的任务）、DiscardPolicy（直接丢弃被拒绝的任务）、DiscardOldestPolicy（丢弃工作队列中最老的任务，然后尝试重新提交被拒绝的任务）等。你也可以实现RejectedExecutionHandler接口来定义自己的拒绝策略。

这篇关于Java中的线程池（附有代码示例）的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/698410。

相关文章

Spring事务传播机制最佳实践

Spring事务传播机制最佳实践

《Spring事务传播机制最佳实践》Spring的事务传播机制为我们提供了优雅的解决方案,本文将带您深入理解这一机制,掌握不同场景下的最佳实践,感兴趣的朋友一起看看吧... 目录1. 什么是事务传播行为2. Spring支持的七种事务传播行为2.1 REQUIRED（默认）2.2 SUPPORTS2
阅读更多...
Python函数作用域示例详解

Python函数作用域示例详解

《Python函数作用域示例详解》本文介绍了Python中的LEGB作用域规则,详细解析了变量查找的四个层级,通过具体代码示例,展示了各层级的变量访问规则和特性,对python函数作用域相关知识感兴趣... 目录一、LEGB 规则二、作用域实例2.1 局部作用域（Local）2.2 闭包作用域（Enclos
阅读更多...
怎样通过分析GC日志来定位Java进程的内存问题

怎样通过分析GC日志来定位Java进程的内存问题

《怎样通过分析GC日志来定位Java进程的内存问题》：本文主要介绍怎样通过分析GC日志来定位Java进程的内存问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、GC 日志基础配置1. 启用详细 GC 日志2. 不同收集器的日志格式二、关键指标与分析维度1.
阅读更多...
Java进程异常故障定位及排查过程

Java进程异常故障定位及排查过程

《Java进程异常故障定位及排查过程》：本文主要介绍Java进程异常故障定位及排查过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、故障发现与初步判断1. 监控系统告警2. 日志初步分析二、核心排查工具与步骤1. 进程状态检查2. CPU 飙升问题3. 内存
阅读更多...
java中新生代和老生代的关系说明

java中新生代和老生代的关系说明

《java中新生代和老生代的关系说明》：本文主要介绍java中新生代和老生代的关系说明,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、内存区域划分新生代老年代二、对象生命周期与晋升流程三、新生代与老年代的协作机制1. 跨代引用处理2. 动态年龄判定3. 空间分
阅读更多...
Java设计模式---迭代器模式(Iterator)解读

Java设计模式---迭代器模式(Iterator)解读

《Java设计模式---迭代器模式(Iterator)解读》：本文主要介绍Java设计模式---迭代器模式(Iterator),具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,... 目录1、迭代器（Iterator）1.1、结构1.2、常用方法1.3、本质1、解耦集合与遍历逻辑2、统一
阅读更多...
Java内存分配与JVM参数详解(推荐)

Java内存分配与JVM参数详解(推荐)

《Java内存分配与JVM参数详解(推荐)》本文详解JVM内存结构与参数调整,涵盖堆分代、元空间、GC选择及优化策略,帮助开发者提升性能、避免内存泄漏,本文给大家介绍Java内存分配与JVM参数详解,... 目录引言JVM内存结构JVM参数概述堆内存分配年轻代与老年代调整堆内存大小调整年轻代与老年代比例元空
阅读更多...
深度解析Java DTO(最新推荐)

深度解析Java DTO(最新推荐)

《深度解析JavaDTO(最新推荐)》DTO（DataTransferObject）是一种用于在不同层（如Controller层、Service层）之间传输数据的对象设计模式,其核心目的是封装数据,... 目录一、什么是DTO？DTO的核心特点：二、为什么需要DTO？（对比Entity）三、实际应用场景解析
阅读更多...
Java 线程安全与 volatile与单例模式问题及解决方案

Java 线程安全与 volatile与单例模式问题及解决方案

《Java线程安全与volatile与单例模式问题及解决方案》文章主要讲解线程安全问题的五个成因（调度随机、变量修改、非原子操作、内存可见性、指令重排序）及解决方案,强调使用volatile关键字... 目录什么是线程安全线程安全问题的产生与解决方案线程的调度是随机的多个线程对同一个变量进行修改线程的修改操
阅读更多...
从原理到实战深入理解Java 断言assert

从原理到实战深入理解Java 断言assert

《从原理到实战深入理解Java断言assert》本文深入解析Java断言机制,涵盖语法、工作原理、启用方式及与异常的区别,推荐用于开发阶段的条件检查与状态验证,并强调生产环境应使用参数验证工具类替代... 目录深入理解 Java 断言（assert）：从原理到实战引言：为什么需要断言？一、断言基础1.1 语
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2