Java 线程池创建方式大揭秘!互联网大厂后端开发必看
moboyou 2025-06-05 16:49 3 浏览
你在互联网大厂做后端开发时,在使用 Java 线程池方面,有没有遇到过不知道该怎么创建的情况呢?项目需求一来,多线程任务一布置,线程池该如何正确创建,成了很多开发者头疼的问题。今天,咱们就深入聊聊 Java 中线程池的创建方式,帮你彻底解决这个困扰!
互联网大厂后端开发为什么离不开线程池?
在互联网大厂的后端开发场景中,高并发、大数据量处理是家常便饭。以电商平台的大促活动为例,海量用户同时下单、查询订单信息,服务器需要同时处理成千上万的请求。这时候,线程池就显得尤为重要。如果没有合理使用线程池,要么创建过多线程导致资源耗尽,服务器崩溃;要么线程数量不足,任务堆积,用户等待时间过长,严重影响用户体验。而且,Java 作为互联网后端开发的主流语言之一,其线程池机制是保障程序高效稳定运行的关键。但很多开发者对于线程池的创建,仅仅停留在一知半解的层面,这就很容易在实际开发中埋下隐患。
Java 线程池创建方式详解
Java 中线程池的创建方式主要有以下几种:
使用 Executors 工厂类创建
FixedThreadPool
通过
Executors.newFixedThreadPool(int nThreads)方法创建,它会创建一个固定大小的线程池,池中线程数量固定不变。当有新任务提交时,如果线程池中有空闲线程,就会立即执行任务;如果没有空闲线程,任务会被暂存到一个阻塞队列中,等待有线程空闲时再执行。
示例:假设我们有一个电商订单处理系统,需要同时处理 10 个订单的支付请求,每个支付请求都需要一个线程来处理。为了避免线程过多导致资源竞争,我们可以使用 FixedThreadPool 来创建一个固定大小为 10 的线程池。
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class FixedThreadPoolExample {
public static void main(String[] args) {
ExecutorService executorService = Executors.newFixedThreadPool(10);
for (int i = 0; i < 20; i++) {
final int orderId = i;
executorService.submit(() -> {
// 模拟处理订单支付逻辑
System.out.println("处理订单 " + orderId + " 的支付请求");
});
}
executorService.shutdown();
}
}
这种线程池适用于处理固定数量并发任务的场景,比如数据库连接池,保证固定数量的线程同时访问数据库,避免资源竞争。
CachedThreadPool
使用
Executors.newCachedThreadPool()创建,它是一个可缓存的线程池。如果线程池长度超过处理需求,可灵活回收空闲线程,若无可回收,则新建线程。它比较适合处理执行时间短、突发性大量请求的任务。
示例:在一个日志收集系统中,会不定期有大量的日志记录任务产生。我们可以使用 CachedThreadPool 来处理这些任务。
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class CachedThreadPoolExample {
public static void main(String[] args) {
ExecutorService executorService = Executors.newCachedThreadPool();
for (int i = 0; i < 100; i++) {
final int logId = i;
executorService.submit(() -> {
// 模拟记录日志逻辑
System.out.println("记录日志 " + logId);
});
}
executorService.shutdown();
}
}
任务执行完线程就可以被回收,下次有新任务再来时又能快速创建新线程处理。
SingleThreadExecutor
通过
Executors.newSingleThreadExecutor()创建,它只有一个工作线程来执行任务。所有任务按照提交顺序依次执行,保证任务执行的顺序性。
示例:在文件按顺序读写操作的场景中,使用 SingleThreadExecutor 能确保数据的读写顺序。比如,我们要按顺序读取一系列文本文件的内容。
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class SingleThreadExecutorExample {
public static void main(String[] args) {
ExecutorService executorService = Executors.newSingleThreadExecutor();
String[] fileNames = {"file1.txt", "file2.txt", "file3.txt"};
for (String fileName : fileNames) {
final String name = fileName;
executorService.submit(() -> {
// 模拟按顺序读取文件内容逻辑
System.out.println("读取文件 " + name + " 的内容");
});
}
executorService.shutdown();
}
}
ScheduledThreadPool
使用
Executors.newScheduledThreadPool(int corePoolSize)创建,它可以实现定时任务和周期性任务的执行。
示例:在电商系统中,每天凌晨 2 点需要统计前一天的销售数据。我们可以使用 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 scheduledExecutorService = Executors.newScheduledThreadPool(1);
scheduledExecutorService.scheduleAtFixedRate(() -> {
// 模拟统计销售数据逻辑
System.out.println("统计销售数据");
}, 0, 1, TimeUnit.DAYS);
}
}
通过schedule()方法可以延迟执行任务,scheduleAtFixedRate()和scheduleWithFixedDelay()方法可以实现周期性任务的执行。
通过 ThreadPoolExecutor 类手动创建
ThreadPoolExecutor 是创建线程池的核心类,通过它我们可以更灵活地配置线程池的参数。它的构造函数如下:
public ThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory,
RejectedExecutionHandler handler)
- corePoolSize:核心线程数,线程池创建后默认会创建的线程数量,即使这些线程处于空闲状态,也不会被销毁(除非设置了allowCoreThreadTimeOut为true)。
- maximumPoolSize:最大线程数,线程池中允许存在的最大线程数量。当任务队列满了且工作线程数小于最大线程数时,线程池会创建新的线程来处理任务。
- keepAliveTime:空闲线程的存活时间。当线程池中的线程数量大于核心线程数时,如果某个线程空闲时间超过keepAliveTime,就会被销毁,直到线程池中的线程数量等于核心线程数。
- unit:keepAliveTime的时间单位,如TimeUnit.MILLISECONDS(毫秒)、TimeUnit.SECONDS(秒)等。
- workQueue:任务队列,用于存放等待执行的任务。常见的有ArrayBlockingQueue(有界队列)、LinkedBlockingQueue(无界队列)等。
- threadFactory:线程工厂,用于创建线程,一般使用默认的线程工厂即可,也可以自定义线程工厂来设置线程的名称、优先级等属性。
- handler:拒绝策略,当任务队列已满且线程数达到最大线程数时,新提交的任务会被拒绝,此时就需要通过拒绝策略来处理这些被拒绝的任务。常见的拒绝策略有AbortPolicy(抛出异常)、CallerRunsPolicy(在调用者线程中执行任务)、DiscardPolicy(丢弃任务)、DiscardOldestPolicy(丢弃队列中最老的任务,然后重新提交当前任务)。
示例:我们创建一个线程池,核心线程数为 5,最大线程数为 10,空闲线程存活时间为 60 秒,任务队列使用有界的ArrayBlockingQueue,容量为 20,拒绝策略采用CallerRunsPolicy。
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class ThreadPoolExecutorExample {
public static void main(String[] args) {
BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<>(20);
ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(
5,
10,
60,
TimeUnit.SECONDS,
workQueue,
new ThreadPoolExecutor.CallerRunsPolicy()
);
for (int i = 0; i < 50; i++) {
final int taskId = i;
threadPoolExecutor.submit(() -> {
// 模拟任务执行逻辑
System.out.println("执行任务 " + taskId);
});
}
threadPoolExecutor.shutdown();
}
}
手动创建线程池虽然相对复杂,但却能让我们根据具体的业务场景,精准地配置各项参数,以达到最佳的性能和资源利用效果。
总结
以上就是 Java 中线程池常见的创建方式。在互联网大厂后端开发中,掌握这些创建方式,合理配置线程池参数,能让你的程序在高并发场景下更加稳定、高效地运行。希望大家都能熟练运用线程池,在项目开发中少踩坑!如果你在实际使用线程池的过程中有任何问题,或者有独特的经验,欢迎在评论区留言分享,咱们一起交流探讨,共同进步!
- 上一篇:Qt多线程创建
- 下一篇:Java中的多线程编程(超详细总结)
相关推荐
- python多线程实现查找目录下有没有相同哈希值的文件
-
python多线程实现查找目录下有没有相同的文件,列出哈希值相同的文件importosimporthashlibfromconcurrent.futuresimportThreadPoo...
- Java、Go 和 Python 多线程性能对比
-
大家好,我是难瓜。今天分享多线程下这三门语言的表现。简介在计算机中,线程是可以由处理器独立执行的小指令序列。多线程在一个进程中是可能的,其中它们共享资源,例如指令和上下文。发现在运行多线程进程时效率最...
- 干货分享丨Python多线程之_thread与threading模块
-
在Python程序中,多线程的应用程序会创建一个函数,来执行需要重复执行多次的程序代码,然后创建一个线程执行该函数。一个线程是一个应用程序单元,用于在后台并行执行多个耗时的动作。在多线程的应用程序中,...
- 一文带您了解Python中的并发:异步(Asyncio)和多线程(Thread)
-
Python以其简单性和多样性而闻名,是一种适用于广泛应用领域的编程语言。在处理多个任务并发时,Python提供了两种主要方法:Asyncio用于异步编程,Multithreading用于管理多个...
- 解锁Python并发编程:多线程和多进程的神秘面纱揭晓
-
欢迎来到我们的系列博客《Python全景系列》!在这个系列中,我们将带领你从Python的基础知识开始,一步步深入到高级话题,帮助你掌握这门强大而灵活的编程语法。无论你是编程新手,还是有一定基础的开发...
- Python多线程-基础篇
-
一、多线程相关概念1.并发和并行的区别并发和并行是即相似又有区别的两个概念,并行是指两个或者多个事件在同一时刻同时执行,而并发是指两个或多个事件通过时间片轮流被执行。从计算机工作原理的角度出发,“并发...
- PYTHON多线程实现web服务器httpserver实例
-
PYTHON多线程实现web服务器importhttp.serverimportsocketserverimportthreading#服务器监听的端口PORT=8000#...
- 如何编写Python漏洞验证脚本(单线程和多线程)
-
我们实战经常会遇到以下几个问题:1、遇到一个利用步骤十分繁琐的漏洞,中间错一步就无法利用2、挖到一个通用漏洞,想要批量刷洞小赚一波,但手动去测试每个网站工作量太大这个时候编写一个poc脚本将会减轻...
- Python 多线程高频面试题,直接把这些答案“甩在”面试官脸上
-
点赞、收藏、加关注,下次找我不迷路不管你是刚入行的新手,还是有一定经验的开发者,掌握多线程的核心问题,都能让你在面试中脱颖而出。今天咱就来盘一盘5个高频的Python多线程面试题,用通俗易懂...
- python多进程和多线程的使用和对比
-
介绍多线程和多进程是常见的并发编程模型,它们被广泛应用于各种类型的应用程序中。在本文中,我将就Python多线程和多进程进行详细的对比。首先,让我们来看一下Python多线程。多线程是一种并发编程模型...
- 24-3-Python多线程-线程队列-queue模块
-
3-1-概念queue模块提供了多线程编程中的队列实现,队列是线程安全的数据结构,能在多线程环境下安全地进行数据交换。3-2-queue的队列类型Queue(先进先出队列)、LifoQueue(后进...
- 玩蛇(Python) - 并发编程之多线程
-
一、线程简介线程(thread)是操作系统能够进行运算调度的最小单位。它被包含在进程之中,是进程中的实际运作单位。由于线程是操作系统直接支持的执行单元,因此,高级语言通常都内置多线程的支持,Pytho...
- Python多进程与多线程应用场景对比
-
在Python中,多进程(Multiprocessing)和多线程(Multithreading)的选择取决于任务类型(I/O密集型vsCPU密集型)、Python的GIL限制以及并...
- Python多线程,守护线程和非守护线程,线程的join方法,代码案例
-
守护线程和非守护线程守护线程&&非守护线程守护线程,是和主线程一起结束的线程,叫守护线程,非守护线程,主线程的结束不影响该线程的执行,主线程结束非守护线程不会立刻结束,也叫用户线程。Python的守护...
- Python3中最常用的5种线程锁你会用吗
-
前言本章节将继续围绕threading模块讲解,基本上是纯理论偏多。对于日常开发者来讲很少会使用到本章节的内容,但是对框架作者等是必备知识,同时也是高频的面试常见问题。私信小编01即可获取大量Pyth...
- 一周热门
- 最近发表
- 标签列表
-
- curseforge官网网址 (16)
- 外键约束 oracle (36)
- oracle的row number (32)
- 唯一索引 oracle (34)
- oracle in 表变量 (28)
- oracle导出dmp导出 (28)
- oracle 数据导出导入 (16)
- oracle两个表 (20)
- 启动oracle的监听服务 (13)
- oracle 数据库 字符集 (20)
- powerdesigner oracle (13)
- oracle修改端口 (15)
- 左连接 oracle (15)
- oracle 标准版 (13)
- oracle 转义字符 (14)
- oracle安装补丁 (19)
- matlab归一化 (16)
- matlab脚本 (14)
- matlab阶跃函数 (14)
- 三次样条插值matlab (14)
- 共轭梯度法matlab (16)
- matlab化简多项式 (20)
- 在线客服网页源码 (14)
- 多线程的创建方式 (29)
- 多线程 python (30)