热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

Java多线程并发控制:解决相同key的线程互斥问题

本文探讨了在Java多线程环境下,如何确保具有相同key值的线程能够互斥执行并按顺序输出结果。通过优化代码结构和使用线程安全的数据结构,我们解决了线程同步问题,并实现了预期的并发行为。
在Java多线程编程中,确保多个线程之间正确、有序地执行是一个常见的挑战。本文将通过一个具体案例,详细讲解如何实现当多个线程调用同一方法时,如果传递的key相等,则这些线程需要互斥排队输出结果。

### 问题描述
现有程序同时启动了4个线程去调用`TestDo.doSome(key, value)`方法,该方法内部先暂停1秒,然后再输出以秒为单位的当前时间值。由于所有线程几乎同时启动,因此会打印出相同的时间值。例如:

```
4:4:1258444892
1:1:1258444892
3:3:1258444892
1:2:1258444892
```

### 需求分析
为了确保具有相同key值的线程能够互斥执行并按顺序输出结果,我们需要对代码进行修改。具体来说,当两个或多个线程的key相等时,它们应该依次输出结果,且每个线程比前一个线程晚1秒输出;而不同key值的线程则可以并行执行。

### 解决方案
我们可以通过引入一个线程安全的集合来存储key值,并在`doSome`方法中使用互斥锁来确保相同key值的线程能够互斥执行。以下是具体的实现步骤:

1. **使用线程安全的集合**:为了避免在遍历集合时出现线程不安全的问题,我们可以使用`CopyOnWriteArrayList`,它是一个线程安全的集合。

2. **互斥锁的实现**:对于每个key值,我们使用一个唯一的对象作为互斥锁。如果多个线程的key值相同,则它们将共享同一个互斥锁对象,从而确保它们按顺序执行。

### 修改后的代码
```java
package cn.edu.hpu.test;

import java.util.concurrent.CopyOnWriteArrayList;

public class ThreadTest9 extends Thread {
private TestDo testDo;
private String key;
private String value;

public ThreadTest9(String key, String key2, String value) {
this.testDo = TestDo.getInstance();
this.key = key + key2;
this.value = value;
}

public static void main(String[] args) {
ThreadTest9 a = new ThreadTest9("1", "", "1");
ThreadTest9 b = new ThreadTest9("1", "", "2");
ThreadTest9 c = new ThreadTest9("3", "", "3");
ThreadTest9 d = new ThreadTest9("4", "", "4");
System.out.println("begin:" + (System.currentTimeMillis() / 1000));
a.start();
b.start();
c.start();
d.start();
}

public void run() {
testDo.doSome(key, value);
}
}

class TestDo {
private TestDo() {}
private static TestDo _instance = new TestDo();
private CopyOnWriteArrayList keys = new CopyOnWriteArrayList<>();

public static TestDo getInstance() {
return _instance;
}

public void doSome(String key, String value) {
Object o = key;
if (!keys.contains(o)) {
keys.add(o);
} else {
for (String k : keys) {
if (k.equals(o)) {
o = k;
break;
}
}
}
synchronized (o) {
try {
Thread.sleep(1000);
System.out.println(key + ":" + value + ":" + (System.currentTimeMillis() / 1000));
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
```

### 结果验证
通过上述修改,运行多次后可以观察到,具有相同key值的线程能够按顺序输出结果,而不同key值的线程则可以并行执行。例如:

```
4:4:1258444892
1:1:1258444892
3:3:1258444892
1:2:1258444896
```

这种实现方式不仅解决了线程同步问题,还提高了程序的稳定性和可读性。
推荐阅读
  • 并发编程:深入理解设计原理与优化
    本文探讨了并发编程中的关键设计原则,特别是Java内存模型(JMM)的happens-before规则及其对多线程编程的影响。文章详细介绍了DCL双重检查锁定模式的问题及解决方案,并总结了不同处理器和内存模型之间的关系,旨在为程序员提供更深入的理解和最佳实践。 ... [详细]
  • 作者:守望者1028链接:https:www.nowcoder.comdiscuss55353来源:牛客网面试高频题:校招过程中参考过牛客诸位大佬的面经,但是具体哪一块是参考谁的我 ... [详细]
  • 深入解析Java虚拟机(JVM)架构与原理
    本文旨在为读者提供对Java虚拟机(JVM)的全面理解,涵盖其主要组成部分、工作原理及其在不同平台上的实现。通过详细探讨JVM的结构和内部机制,帮助开发者更好地掌握Java编程的核心技术。 ... [详细]
  • 在高并发需求的C++项目中,我们最初选择了JsonCpp进行JSON解析和序列化。然而,在处理大数据量时,JsonCpp频繁抛出异常,尤其是在多线程环境下问题更为突出。通过分析发现,旧版本的JsonCpp存在多线程安全性和性能瓶颈。经过评估,我们最终选择了RapidJSON作为替代方案,并实现了显著的性能提升。 ... [详细]
  • 深入解析 Android IPC 中的 Messenger 机制
    本文详细介绍了 Android 中基于消息传递的进程间通信(IPC)机制——Messenger。通过实例和源码分析,帮助开发者更好地理解和使用这一高效的通信工具。 ... [详细]
  • 深入理解Java多线程并发处理:基础与实践
    本文探讨了Java中的多线程并发处理机制,从基本概念到实际应用,帮助读者全面理解并掌握多线程编程技巧。通过实例解析和理论阐述,确保初学者也能轻松入门。 ... [详细]
  • 深入了解 Windows 窗体中的 SplitContainer 控件
    SplitContainer 控件是 Windows 窗体中的一种复合控件,由两个可调整大小的面板和一个可移动的拆分条组成。本文将详细介绍其功能、属性以及如何通过编程方式创建复杂的用户界面。 ... [详细]
  • 实体映射最强工具类:MapStruct真香 ... [详细]
  • Startup 类配置服务和应用的请求管道。Startup类ASP.NETCore应用使用 Startup 类,按照约定命名为 Startup。 Startup 类:可选择性地包括 ... [详细]
  • 本文介绍如何在华为CE交换机上配置M-LAG(多链路聚合组),以实现CE1和CE2设备作为VLAN 10网关的高可用性。通过详细的配置步骤,确保网络冗余和稳定性。 ... [详细]
  • 本文作者分享了在阿里巴巴获得实习offer的经历,包括五轮面试的详细内容和经验总结。其中四轮为技术面试,一轮为HR面试,涵盖了大量的Java技术和项目实践经验。 ... [详细]
  • JavaScript 基础语法指南
    本文详细介绍了 JavaScript 的基础语法,包括变量、数据类型、运算符、语句和函数等内容,旨在为初学者提供全面的入门指导。 ... [详细]
  • 深入解析Spring启动过程
    本文详细介绍了Spring框架的启动流程,帮助开发者理解其内部机制。通过具体示例和代码片段,解释了Bean定义、工厂类、读取器以及条件评估等关键概念,使读者能够更全面地掌握Spring的初始化过程。 ... [详细]
  • 深入解析动态代理模式:23种设计模式之三
    在设计模式中,动态代理模式是应用最为广泛的一种代理模式。它允许我们在运行时动态创建代理对象,并在调用方法时进行增强处理。本文将详细介绍动态代理的实现机制及其应用场景。 ... [详细]
  • 深入解析Java多线程与并发库的应用:空中网实习生面试题详解
    本文详细探讨了Java多线程与并发库的高级应用,结合空中网在挑选实习生时的面试题目,深入分析了相关技术要点和实现细节。文章通过具体的代码示例展示了如何使用Semaphore和SynchronousQueue来管理线程同步和任务调度。 ... [详细]
author-avatar
大大醯_804_224
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有