当前位置：首页 > news >正文

后端并发编程操作简述 Java高并发程序设计六类并发容器七种线程池四种阻塞队列

news 来源：原创 2025/7/20 10:59:50

并发集合

1. ConcurrentHashMap：

2. CopyOnWriteArrayList：

3. CopyOnWriteArraySet：

4. BlockingQueue系列：

5. ConcurrentSkipListMap 和 ConcurrentSkipListSet：

6. ConcurrentLinkedDeque：

注意事项

七种线程池

1. FixedThreadPool

2.CachedThreadPool

3.ScheduledThreadPool

4.SingleThreadExecutor

5.SingleThreadScheduledExecutor

6.ForkJoinPool

7. CustomThreadPool（自定义线程池）

四种阻塞队列

1. ArrayBlockingQueue

2. LinkedBlockingQueue

3. PriorityBlockingQueue

4. DelayQueue

综合示例

1.在实际应用中，应该确保线程池和阻塞队列的正确关闭和资源释放。

2.消费者任务中的无限循环需要额外的机制来优雅地终止，例如使用中断或额外的停止标志。

3.根据具体需求选择合适的线程池和阻塞队列实现。

并发集合

除了 ConcurrentLinkedQueue 之外， Java 还提供了多种并发集合类，以满足不同场景下的并发需求。

以下是一些常见的并发集合类：

1. ConcurrentHashMap：

这是一个线程安全的哈希表实现，针对多线程环境进行了优化，以减少锁竞争从而提高性

能。

它通过分段锁（在 JDK8 之前）或 CAS （ Compare-And-Swap ）操作（在 JDK8 及之后）来实现

高效的并发访问。

适用于多线程操作大量数据，且读操作远多于写操作的场景。

2. CopyOnWriteArrayList：

这是一个线程安全的可变数组，其中所有可变操作（如添加、设置等）都是通过对底层数组

的复制来实现的。

适用于读多写少的场景，因为写操作需要复制整个数组，开销较大。

迭代器是弱一致性的，即在遍历过程中可能看不到其他线程的修改。

3. CopyOnWriteArraySet：

这是一个线程安全的 Set 实现，基于 CopyOnWriteArrayList 。

继承了 CopyOnWriteArrayList 的线程安全性和弱一致性迭代器的特性。

4. BlockingQueue系列：

这是一个支持阻塞操作的队列接口，其实现类包括 ArrayBlockingQueue 、

LinkedBlockingQueue 、 PriorityBlockingQueue 、 DelayQueue 、 SynchronousQueue

和 LinkedBlockingDeque 等。

这些队列在插入和移除元素时，如果队列为空或已满，则会根据具体情况阻塞调用线程或抛

出异常。

常用于生产者 - 消费者问题，以及需要线程间协调的场景。

5. ConcurrentSkipListMap 和 ConcurrentSkipListSet：

这两个类是基于跳表（ Skip List ）的并发实现。

提供了快速的并发访问能力，并且支持有序的数据结构。

适用于跨多个线程共享访问的有序数据，以及在并发情况下需要排序功能的场景。

6. ConcurrentLinkedDeque：

这是一个线程安全的双端队列，支持在队列的两端进行高效的插入和删除操作。

适用于需要频繁在队列两端进行操作的场景。

这些并发集合类在内部实现了必要的同步策略，确保了在多线程环境下的线程安全性。开发者可以根据

具体的需求和场景，选择合适的并发集合类来提高程序的并发性能和安全性

当然，以下是在上述代码的基础上添加了详细注释的版本，以帮助理解每个部分的作用和目的：

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;public class ConcurrentWriteExample {// 定义线程数量和每个线程写入的次数private static final int NUM_THREADS = 10;private static final int NUM_WRITES_PER_THREAD = 100;// 共享资源：一个线程安全的ArrayList（实际上这里不是线程安全的，因为我们会手动添加锁）// 注意：如果直接使用ArrayList进行并发写入，需要外部同步机制。// 更推荐使用ConcurrentLinkedQueue或其他并发集合。private static final List<String> sharedList = new ArrayList<>();// 用于控制对共享资源的访问的锁private static final Lock lock = new ReentrantLock();public static void main(String[] args) {// 创建一个固定大小的线程池ExecutorService executorService = Executors.newFixedThreadPool(NUM_THREADS);// 提交多个任务到线程池for (int i = 0; i < NUM_THREADS; i++) {executorService.submit(() -> {// 每个任务会循环写入数据到共享列表中for (int j = 0; j < NUM_WRITES_PER_THREAD; j++) {writeData("Data from thread " + Thread.currentThread().getId());}});}// 关闭线程池，不再接受新任务，但会继续执行已提交的任务executorService.shutdown();// 等待所有任务完成// 注意：在实际应用中，更推荐使用awaitTermination来等待指定时间或直到任务完成，// 并且要处理InterruptedException。这里的简单while循环只是为了演示。while (!executorService.isTerminated()) {// 等待所有任务完成}// 打印共享列表的大小和内容，以验证并发写入的结果System.out.println("Shared list size: " + sharedList.size());System.out.println("Shared list content: " + sharedList);}// 写入数据到共享列表的方法，使用锁来确保线程安全private static void writeData(String data) {// 获取锁，如果锁不可用，则当前线程会阻塞直到锁可用lock.lock();try {// 在锁的保护下，安全地向共享列表添加数据sharedList.add(data);} finally {// 确保无论如何都会释放锁，以避免死锁lock.unlock();}}
}

注释中强调了以下几点：

1. 线程数量和写入次数 ：定义了将有多少线程同时运行，以及每个线程将写入多少次数据。

2. 共享资源 ：虽然这里使用了 ArrayList ，但它是非线程安全的。我们通过外部添加

ReentrantLock 来确保线程安全。在实际应用中，更推荐使用 java.util.concurrent 包中的并

发集合。

3. 锁：使用 ReentrantLock 来控制对共享资源的访问，确保同一时间只有一个线程可以写入数据。

4. 线程池 ：使用 ExecutorService 来管理线程池，这样可以更高效地管理线程的生命周期和资源。

5. 任务提交 ：将多个任务提交到线程池，每个任务都会执行写入操作。

6. 等待任务完成 ：使用 shutdown() 方法关闭线程池，并使用 while 循环等待所有任务完成。在实

际应用中，更推荐使用 awaitTermination() 方法。

7. 打印结果 ：在所有任务完成后，打印共享列表的大小和内容，以验证并发写入的结果是否正确。

请注意，虽然这个示例展示了如何使用锁来实现线程安全的并发写入，但在实际应用中，如果可能的

话，更推荐使用 java.util.concurrent 包中提供的并发集合和工具类，因为它们通常提供了更高的性

能和更好的可扩展性。

注意事项

使用 ReentrantLock 可以确保对共享资源的互斥访问，但也会引入一定的性能开销。

在实际应用中，如果可以使用 java.util.concurrent 包中的其他并发集合（如

ConcurrentHashMap 、 CopyOnWriteArrayList 等），则可能更合适，因为这些集合已经内置

了线程安全机制。

始终注意死锁和性能问题，特别是在高并发场景下。

这个示例展示了基本的并发写入实现，但在实际应用中，可能需要根据具体需求进行更复杂的处理。

Java 中的 java.util.concurrent 包提供了丰富的线程池和阻塞队列实现，用于满足不同的并发需

求。以下是 Java 中的七种主要线程池和四种常见阻塞队列的详细举例、演示及特点说明，并附有代码

注释。

七种线程池

1. FixedThreadPool

特点：固定数量的线程池，线程数量在创建时指定，任务队列为无界链表。

示例：

// 创建一个固定大小的线程池
ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3);

2.CachedThreadPool

特点：会根据需要创建新线程，如果空闲线程超过 60 秒则会被回收，任务队列为同步队列

（无存储能力）。

示例：

// 创建一个可缓存的线程池
ExecutorService cachedThreadPool = Executors.newCachedThreadPool();

3.ScheduledThreadPool

特点：可以调度任务在给定的延迟后运行，或者定期执行。

示例：

// 创建一个调度线程池
ScheduledExecutorService scheduledThreadPool =
Executors.newScheduledThreadPool(3);
scheduledThreadPool.schedule(() -> {
System.out.println("Task executed after delay");
}, 1, TimeUnit.SECONDS);

4.SingleThreadExecutor

特点：单线程执行器，确保任务按顺序执行，任务队列为无界链表

示例:

// 创建一个单线程的线程池
ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();

5.SingleThreadScheduledExecutor

特点：单线程调度执行器，确保任务按顺序执行，且可以调度任务。

示例（基于 ScheduledThreadPool 简化）：

// 实际上可以通过ScheduledThreadPool(1)来实现单线程调度
ScheduledExecutorService singleThreadScheduledExecutor =
Executors.newScheduledThreadPool(1);

6.ForkJoinPool

特点：用于执行分而治之算法的任务，适用于大量小规模任务的并行处理。

示例：

// 创建一个ForkJoinPool
ForkJoinPool forkJoinPool = new ForkJoinPool();
forkJoinPool.submit(() -> {
// 分而治之的任务
});

7. CustomThreadPool（自定义线程池）

特点：通过 ThreadPoolExecutor 构造函数自定义线程池的核心线程数、最大线程数、存

活时间、任务队列等。

示例：

// 创建一个自定义的线程池
ThreadPoolExecutor customThreadPool = new ThreadPoolExecutor(
2, // 核心线程数
4, // 最大线程数
60L, // 线程存活时间
TimeUnit.SECONDS, // 时间单位
new LinkedBlockingQueue<Runnable>() // 任务队列
);

四种阻塞队列

1. ArrayBlockingQueue

特点：基于数组的阻塞队列，有界， FIFO （先进先出）顺序。

示例：

BlockingQueue<Integer> arrayBlockingQueue = new ArrayBlockingQueue<>(10);

2. LinkedBlockingQueue

特点：基于链表的阻塞队列，可选有界或无界， FIFO 顺序，吞吐量通常高于

ArrayBlockingQueue 。

示例：

BlockingQueue<Integer> linkedBlockingQueue = new LinkedBlockingQueue<>();

3. PriorityBlockingQueue

特点：支持优先级的阻塞队列，无界，基于优先级（自然顺序或提供的 Comparator ）进行

排序。

示例：

BlockingQueue<Integer> priorityBlockingQueue = new PriorityBlockingQueue<>();

4. DelayQueue

特点：支持延迟获取元素的阻塞队列，无界，元素只有在其延迟期满时才能被提取。

示例：

BlockingQueue<DelayedElement> delayQueue = new DelayQueue<>();
// DelayedElement 需要实现 Delayed 接口

综合示例

由于篇幅限制，这里只提供一个综合使用 FixedThreadPool 和 ArrayBlockingQueue 的示例，并简

要说明其他线程池和队列的用法。

import java.util.concurrent.*;public class ThreadPoolAndBlockingQueueExample {public static void main(String[] args) {// 创建一个固定大小的线程池ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3);// 创建一个有界的阻塞队列BlockingQueue<Integer> arrayBlockingQueue = new ArrayBlockingQueue<>(10);// 生产者任务Runnable producer = () -> {try {for (int i = 0; i < 20; i++) {arrayBlockingQueue.put(i); // 如果队列满了，会阻塞System.out.println("Produced: " + i);}} catch (InterruptedException e) {Thread.currentThread().interrupt();}};// 消费者任务Runnable consumer = () -> {try {while (!Thread.currentThread().isInterrupted()) {Integer value = arrayBlockingQueue.take(); // 如果队列空了，会阻塞System.out.println("Consumed: " + value);// 模拟任务处理时间Thread.sleep(500);}} catch (InterruptedException e) {Thread.currentThread().interrupt();}};// 提交生产者任务给线程池fixedThreadPool.submit(producer);// 提交多个消费者任务给线程池（这里为了演示只提交一个，实际可以根据需要提交多个）fixedThreadPool.submit(consumer);// 注意：为了示例简洁，这里没有添加关闭线程池的代码。在实际应用中，应该在适当的时候调用 shutdown() 方法。// 优雅地关闭线程池try {Thread.sleep(10000); // 等待一段时间，允许生产者和消费者执行} catch (InterruptedException e) {Thread.currentThread().interrupt();}// 关闭线程池fixedThreadPool.shutdown();}
}

注意：

1.在实际应用中，应该确保线程池和阻塞队列的正确关闭和资源释放。

2.消费者任务中的无限循环需要额外的机制来优雅地终止，例如使用中断或额外的停止标志。

3.根据具体需求选择合适的线程池和阻塞队列实现。

后端并发编程操作简述 Java高并发程序设计六类并发容器七种线程池四种阻塞队列

目录并发集合 1. ConcurrentHashMap： 2. CopyOnWriteArrayList： 3. CopyOnWriteArraySet： 4. BlockingQueue系列： 5. ConcurrentSkipListMap 和 ConcurrentSkipListSet： 6. ConcurrentLinkedDeque：…...

编程日记 2025/7/20 10:59:50

基于LLama_factory的Qwen2.5大模型的微调笔记

Qwen2.5大模型微调记录 LLama-facrotyQwen2.5 模型下载。huggingface 下载方式Modelscope 下载方式数据集准备模型微调模型训练模型验证及推理模型导出部署推理vllm 推理Sglang 推理 LLama-facroty 根据git上步骤安装即可，要求的软硬件都装上。 llama-factory运行…...

编程日记 2025/7/11 19:13:29

resnet50,clip，Faiss+Flask简易图文搜索服务

一、实现文件夹目录结构： templates -----upload.html faiss_app.py 前端代码： <!DOCTYPE html> <html lang"en"> <head><meta charset"UTF-8"><meta name"viewport" content"widt…...

编程日记 2025/7/8 1:15:10

亚信安全与飞书达成深度合作

近日，亚信安全联合飞书举办的“走近先进”系列活动正式走进亚信。活动以“安全护航信息化共筑数字未来路”为主题，吸引了众多数字化转型前沿企业的近百位领导参会。作为“走近先进”系列的第二场活动，本场活动更加深入挖掘了数字化转型的基础…...

编程日记 2025/7/19 8:14:09

Spring框架特性及包下载（Java EE 学习笔记04）

1 Spring 5的新特性 Spring 5是Spring当前最新的版本，与历史版本对比，Spring 5对Spring核心框架进行了修订和更新，增加了很多新特性，如支持响应式编程等。更新JDK基线因为Spring 5代码库运行于JDK 8之上，所以Spri…...

编程日记 2025/7/15 23:44:40

C# 使用HangFire 第一章：.net Framework 4.6 WebAPI 使用Hangfire 第二章：net 8使用hangfire实现库存同步任务文章目录 C# 使用HangFire前言项目源码一、项目架构二、项目服务介绍HangFire服务结构解析HangfireCollectionExtensions 类ModelHangfireSettingsHttpAuthInfoUs…...

编程日记 2025/7/19 15:44:11

python VS c++

一、语法特点 Python： 语法简洁、优雅，代码可读性极强，采用缩进来表示代码块，摒弃了像 C 那样使用大括号的传统方式，使得代码看上去十分清晰简洁。例如： if 5 > 3:print("5大于3") elif 5 …...

编程日记 2025/7/14 11:05:12

windows C#-属性

属性提供了一种将元数据或声明性信息与代码(程序集、类型、方法、属性等)关联的强大方法。将属性与程序实体关联后，可以使用称为反射的技术在运行时查询该属性。属性具有以下属性： 属性将元数据添加到您的程序中。元数据是有关程序中定义的类型的信息…...

编程日记 2025/7/19 13:58:41

Redis常见面试题总结(上)

Redis 基础什么是 Redis？ Redis （REmote DIctionary Server）是一个基于 C 语言开发的开源 NoSQL 数据库（BSD 许可）。与传统数据库不同的是，Redis 的数据是保存在内存中的（内存数据库&#xf…...

编程日记 2025/7/19 16:45:00

小鹏汽车智慧材料数据库系统项目总成数据同步

1、定时任务处理 2、提供了接口小鹏方面提供的推送的数据表结构： 这几个表总数为100多万，经过条件筛选过滤后大概2万多条数据小鹏的人给的示例图： 界面： SQL: -- 查询车型 select bmm.md_material_id, bmm.material_num, bm…...

编程日记 2025/7/12 1:47:38

风尚云网前端学习：一个简易前端新手友好的HTML5页面布局与样式设计

风尚云网前端学习：一个简易前端新手友好的HTML5页面布局与样式设计简介在前端开发的世界里，HTML5和CSS3是构建现代网页的基石。本文将通过一个简单的HTML5页面模板，展示如何使用HTML5的结构化元素和CSS3的样式特性，来创建一个…...

编程日记 2025/7/15 20:21:49

论文阅读：A fast, scalable and versatile tool for analysis of single-cell omics data

Zhang, K., Zemke, N.R., Armand, E.J. et al. A fast, scalable and versatile tool for analysis of single-cell omics data. Nat Methods 21, 217–227 (2024). 论文地址：https://doi.org/10.1038/s41592-023-02139-9 代码地址：https://github.com…...

编程日记 2025/7/19 12:54:51

【从零开始的LeetCode-算法】43. 网络延迟时间

有 n 个网络节点，标记为 1 到 n。给你一个列表 times，表示信号经过有向边的传递时间。 times[i] (ui, vi, wi)，其中 ui 是源节点，vi 是目标节点， wi 是一个信号从源节点传递到目标节点的时间。现在，…...

编程日记 2025/7/16 5:24:45

一文理解 Python 编程语言中的 .strip() 方法

🍉 CSDN 叶庭云：https://yetingyun.blog.csdn.net/ Python 中的 strip() 方法：初学者友好指南在 Python 中，strip() 是一个极为实用的字符串方法，主要用于移除字符串首尾的特定字符。默认情况下，它会清除…...

编程日记 2025/7/19 23:26:03

solr 远程命令执行 (CVE-2019-17558)

漏洞描述 Apache Velocity是一个基于Java的模板引擎，它提供了一个模板语言去引用由Java代码定义的对象。Velocity是Apache基金会旗下的一个开源软件项目，旨在确保Web应用程序在表示层和业务逻辑层之间的隔离（即MVC设计模式）。 Apa…...

编程日记 2025/7/16 15:25:33

【cocos creator】下拉框

https://download.csdn.net/download/K86338236/90038176 const { ccclass, property } cc._decorator;type DropDownOptionData {optionString?: string,optionSf?: cc.SpriteFrame } type DropDownItemData {label: cc.Label,sprite: cc.Sprite,toggle: cc.Toggle }cccl…...

编程日记 2025/7/9 7:40:06

并发集合

1. ConcurrentHashMap：

2. CopyOnWriteArrayList：

3. CopyOnWriteArraySet：

4. BlockingQueue系列：

5. ConcurrentSkipListMap 和 ConcurrentSkipListSet：

6. ConcurrentLinkedDeque：

注意事项

七种线程池

1. FixedThreadPool

2.CachedThreadPool

3.ScheduledThreadPool

4.SingleThreadExecutor

5.SingleThreadScheduledExecutor

6.ForkJoinPool

7. CustomThreadPool（自定义线程池）

四种阻塞队列

1. ArrayBlockingQueue

2. LinkedBlockingQueue

3. PriorityBlockingQueue

4. DelayQueue

综合示例

1.在实际应用中，应该确保线程池和阻塞队列的正确关闭和资源释放。

2.消费者任务中的无限循环需要额外的机制来优雅地终止，例如使用中断或额外的停止标志。

3.根据具体需求选择合适的线程池和阻塞队列实现。

相关文章：