热门标签 | 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中org.neo4j.helpers.collection.Iterators.single()方法的功能、使用场景及代码示例,帮助开发者更好地理解和应用该方法。 ... [详细]
  • 优化ListView性能
    本文深入探讨了如何通过多种技术手段优化ListView的性能,包括视图复用、ViewHolder模式、分批加载数据、图片优化及内存管理等。这些方法能够显著提升应用的响应速度和用户体验。 ... [详细]
  • Explore a common issue encountered when implementing an OAuth 1.0a API, specifically the inability to encode null objects and how to resolve it. ... [详细]
  • 1:有如下一段程序:packagea.b.c;publicclassTest{privatestaticinti0;publicintgetNext(){return ... [详细]
  • 本文介绍了Java并发库中的阻塞队列(BlockingQueue)及其典型应用场景。通过具体实例,展示了如何利用LinkedBlockingQueue实现线程间高效、安全的数据传递,并结合线程池和原子类优化性能。 ... [详细]
  • Java 中的 BigDecimal pow()方法,示例 ... [详细]
  • 主要用了2个类来实现的,话不多说,直接看运行结果,然后在奉上源代码1.Index.javaimportjava.awt.Color;im ... [详细]
  • 深入解析Spring Cloud Ribbon负载均衡机制
    本文详细介绍了Spring Cloud中的Ribbon组件如何实现服务调用的负载均衡。通过分析其工作原理、源码结构及配置方式,帮助读者理解Ribbon在分布式系统中的重要作用。 ... [详细]
  • 本文介绍如何在 Android 中通过代码模拟用户的点击和滑动操作,包括参数说明、事件生成及处理逻辑。详细解析了视图(View)对象、坐标偏移量以及不同类型的滑动方式。 ... [详细]
  • 本文详细介绍 Go+ 编程语言中的上下文处理机制,涵盖其基本概念、关键方法及应用场景。Go+ 是一门结合了 Go 的高效工程开发特性和 Python 数据科学功能的编程语言。 ... [详细]
  • Explore how Matterverse is redefining the metaverse experience, creating immersive and meaningful virtual environments that foster genuine connections and economic opportunities. ... [详细]
  • 本文详细介绍了如何解决Uploadify插件在Internet Explorer(IE)9和10版本中遇到的点击失效及JQuery运行时错误问题。通过修改相关JavaScript代码,确保上传功能在不同浏览器环境中的一致性和稳定性。 ... [详细]
  • 探讨如何高效使用FastJSON进行JSON数据解析,特别是从复杂嵌套结构中提取特定字段值的方法。 ... [详细]
  • Java 类成员初始化顺序与数组创建
    本文探讨了Java中类成员的初始化顺序、静态引入、可变参数以及finalize方法的应用。通过具体的代码示例,详细解释了这些概念及其在实际编程中的使用。 ... [详细]
  • 本文详细介绍了Java中org.eclipse.ui.forms.widgets.ExpandableComposite类的addExpansionListener()方法,并提供了多个实际代码示例,帮助开发者更好地理解和使用该方法。这些示例来源于多个知名开源项目,具有很高的参考价值。 ... [详细]
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社区 版权所有