0

0

java怎样使用线程池管理线程资源 java线程池应用的实用操作教程​

看不見的法師

看不見的法師

发布时间:2025-08-01 19:45:01

|

407人浏览过

|

来源于php中文网

原创

线程池是用于高效管理和复用线程的机制,避免频繁创建和销毁线程带来的开销。1. 通过executors类的静态方法可创建不同类型的线程池:newfixedthreadpool(int nthreads)创建固定大小线程池,适用于任务稳定、响应要求高的场景;2. newcachedthreadpool()创建可缓存线程池,线程数可扩展,空闲线程60秒后回收,适合任务量波动大但执行时间短的场景;3. newsinglethreadexecutor()创建单线程线程池,保证任务顺序执行;4. newscheduledthreadpool(int corepoolsize)用于支持定时或周期性任务执行。核心参数包括:corepoolsize(核心线程数)、maximumpoolsize(最大线程数)、keepalivetime(空闲线程存活时间)、unit(时间单位)、workqueue(任务队列)、threadfactory(线程工厂)和rejectedexecutionhandler(拒绝策略),其中拒绝策略有abortpolicy(抛异常)、callerrunspolicy(调用者线程执行)、discardpolicy(丢弃任务)和discardoldestpolicy(丢弃最老任务)。关闭线程池时,应优先使用shutdown()方法平滑关闭,允许已提交任务完成执行,再调用awaittermination()等待完成;必要时使用shutdownnow()立即关闭并处理未执行任务列表。示例代码展示了创建固定线程池、提交100个任务、平滑关闭及等待任务完成的完整流程,确保资源安全释放且任务不丢失。

java怎样使用线程池管理线程资源 java线程池应用的实用操作教程​

线程池,简单来说,就是帮你管理线程的。不用你每次都手动创建和销毁线程,效率更高,资源利用也更好。想象一下,你开饭店,线程就是服务员,线程池就是你的服务员调度中心,客人来了,直接从调度中心调服务员,客人走了,服务员休息,不用解雇,等着下次再用。

创建和管理线程,使用

java.util.concurrent.ExecutorService
java.util.concurrent.Executors
这两个类。
Executors
提供了一些静态方法,可以创建不同类型的线程池,而
ExecutorService
则提供了线程池的管理方法,比如提交任务、关闭线程池等。

如何选择合适的线程池类型?

选择线程池类型,得看你的应用场景。不同的线程池,策略不一样。

立即学习Java免费学习笔记(深入)”;

  • newFixedThreadPool(int nThreads)
    : 固定大小的线程池。核心线程数和最大线程数一样,任务队列是无界的
    LinkedBlockingQueue
    。 适合任务量比较稳定,对响应时间要求高的场景。想象一下,你的饭店,永远只雇佣固定数量的服务员,保证服务质量。但如果客人太多,超过服务员的处理能力,客人就得排队等着。

  • newCachedThreadPool()
    : 缓存线程池。线程数可以无限扩展,但空闲线程会被回收(默认空闲 60 秒)。任务队列是
    SynchronousQueue
    ,这意味着每个任务都必须立即被执行,否则会被拒绝。适合任务量波动很大,但每个任务执行时间很短的场景。比如,你开个小吃摊,忙的时候多招几个人,闲的时候就让人休息,节省成本。

  • newSingleThreadExecutor()
    : 单线程的线程池。只有一个线程在执行任务,任务队列是无界的
    LinkedBlockingQueue
    。适合需要顺序执行任务的场景。比如,你开个书店,只有一个收银员,大家必须排队结账。

  • newScheduledThreadPool(int corePoolSize)
    : 定时任务线程池。可以定时或周期性地执行任务。适合需要定时执行任务的场景。比如,你开个闹钟公司,需要定时播放音乐。

    Joker AIx
    Joker AIx

    一站式AI创意生产平台,覆盖图像、视频、音频、文案全品类创作

    下载

选择哪种,主要看你的业务特点,以及对性能的要求。没有绝对的好坏,只有最合适的。

线程池的核心参数有哪些?

理解线程池的参数,才能更好地控制它。

  • corePoolSize
    :
    核心线程数。线程池中始终保持的线程数量。即使线程空闲,也不会被回收。
  • maximumPoolSize
    :
    最大线程数。线程池中允许的最大线程数量。当任务队列满了,且核心线程都在忙,线程池会创建新的线程来执行任务,直到达到最大线程数。
  • keepAliveTime
    :
    线程空闲时间。当线程池中的线程数量超过核心线程数时,多余的空闲线程会在指定时间内被回收。
  • unit
    :
    线程空闲时间的单位。
  • workQueue
    :
    任务队列。用于存放等待执行的任务。
  • threadFactory
    :
    线程工厂。用于创建线程。可以自定义线程的名称、优先级等。
  • rejectedExecutionHandler
    :
    拒绝策略。当任务队列满了,且线程池中的线程数量达到最大线程数时,会执行拒绝策略。常见的拒绝策略有:
    • AbortPolicy
      :直接抛出
      RejectedExecutionException
      异常。
    • CallerRunsPolicy
      :由提交任务的线程来执行任务。
    • DiscardPolicy
      :直接丢弃任务。
    • DiscardOldestPolicy
      :丢弃队列中最老的任务,然后尝试提交新任务。

这些参数,直接影响线程池的性能和行为,需要根据实际情况进行调整。

如何优雅地关闭线程池?

关闭线程池,也需要讲究方法,不然可能会导致任务丢失或程序异常。

  • shutdown()
    :
    平滑关闭线程池。不再接受新的任务,但会等待已提交的任务执行完成。
  • shutdownNow()
    :
    立即关闭线程池。尝试停止所有正在执行的任务,并停止处理等待队列中的任务。返回等待队列中未执行的任务列表。

一般来说,推荐使用

shutdown()
方法,给线程一个缓冲时间,让它们把手头的工作做完。如果必须立即关闭,可以使用
shutdownNow()
,但要注意处理返回的未执行任务列表。

一个简单的例子:

ExecutorService executor = Executors.newFixedThreadPool(10);

// 提交任务
for (int i = 0; i < 100; i++) {
    executor.submit(() -> {
        try {
            Thread.sleep(100); // 模拟任务执行时间
            System.out.println("Task executed by " + Thread.currentThread().getName());
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    });
}

// 关闭线程池
executor.shutdown();

try {
    executor.awaitTermination(1, TimeUnit.MINUTES); // 等待所有任务完成,最多等待1分钟
} catch (InterruptedException e) {
    e.printStackTrace();
}

System.out.println("All tasks completed.");

这段代码创建了一个固定大小的线程池,提交了 100 个任务,然后平滑关闭了线程池,并等待所有任务执行完成。注意

awaitTermination
方法,可以设置等待时间,避免程序一直阻塞。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

WorkBuddy
WorkBuddy

腾讯云推出的AI原生桌面智能体工作台

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
string转int
string转int

在编程中,我们经常会遇到需要将字符串(str)转换为整数(int)的情况。这可能是因为我们需要对字符串进行数值计算,或者需要将用户输入的字符串转换为整数进行处理。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

1031

2023.08.02

int占多少字节
int占多少字节

int占4个字节,意味着一个int变量可以存储范围在-2,147,483,648到2,147,483,647之间的整数值,在某些情况下也可能是2个字节或8个字节,int是一种常用的数据类型,用于表示整数,需要根据具体情况选择合适的数据类型,以确保程序的正确性和性能。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

612

2024.08.29

c++怎么把double转成int
c++怎么把double转成int

本专题整合了 c++ double相关教程,阅读专题下面的文章了解更多详细内容。

334

2025.08.29

C++中int的含义
C++中int的含义

本专题整合了C++中int相关内容,阅读专题下面的文章了解更多详细内容。

235

2025.08.29

线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

765

2023.08.10

TypeScript类型系统进阶与大型前端项目实践
TypeScript类型系统进阶与大型前端项目实践

本专题围绕 TypeScript 在大型前端项目中的应用展开,深入讲解类型系统设计与工程化开发方法。内容包括泛型与高级类型、类型推断机制、声明文件编写、模块化结构设计以及代码规范管理。通过真实项目案例分析,帮助开发者构建类型安全、结构清晰、易维护的前端工程体系,提高团队协作效率与代码质量。

1

2026.03.13

Python异步编程与Asyncio高并发应用实践
Python异步编程与Asyncio高并发应用实践

本专题围绕 Python 异步编程模型展开,深入讲解 Asyncio 框架的核心原理与应用实践。内容包括事件循环机制、协程任务调度、异步 IO 处理以及并发任务管理策略。通过构建高并发网络请求与异步数据处理案例,帮助开发者掌握 Python 在高并发场景中的高效开发方法,并提升系统资源利用率与整体运行性能。

39

2026.03.12

C# ASP.NET Core微服务架构与API网关实践
C# ASP.NET Core微服务架构与API网关实践

本专题围绕 C# 在现代后端架构中的微服务实践展开,系统讲解基于 ASP.NET Core 构建可扩展服务体系的核心方法。内容涵盖服务拆分策略、RESTful API 设计、服务间通信、API 网关统一入口管理以及服务治理机制。通过真实项目案例,帮助开发者掌握构建高可用微服务系统的关键技术,提高系统的可扩展性与维护效率。

140

2026.03.11

Go高并发任务调度与Goroutine池化实践
Go高并发任务调度与Goroutine池化实践

本专题围绕 Go 语言在高并发任务处理场景中的实践展开,系统讲解 Goroutine 调度模型、Channel 通信机制以及并发控制策略。内容包括任务队列设计、Goroutine 池化管理、资源限制控制以及并发任务的性能优化方法。通过实际案例演示,帮助开发者构建稳定高效的 Go 并发任务处理系统,提高系统在高负载环境下的处理能力与稳定性。

47

2026.03.10

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Kotlin 教程
Kotlin 教程

共23课时 | 4.4万人学习

C# 教程
C# 教程

共94课时 | 11.2万人学习

Java 教程
Java 教程

共578课时 | 81.4万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号