备案控制台
开发者社区 云计算 文章 正文

java.util.concurrent包(3)——线程间通信wait/notify和await/signal

2014-06-03 1475
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：
一、线程如何停止
使用stop()不安全。它会解除由线程获取的所有锁定，而且如果对象处于一种不连贯状态，那么其他线程能在那种状态下检查和修改它们。结果很难检查出真正的问题所在。suspend()方法容易发生死锁。调用suspend()的时候，目标线程会停下来，但却仍然持有在这之前获得的锁定。此时其他任何线程都不能访问锁定的资源，除非被"挂起"的线程恢复运行。对任何线程来说，如果它们想恢复目标线程，同时又试图使用任何一个锁定的资源，就会造成死锁。所以不应该使用suspend()。正确的做法是而应在自己的Thread类中置入一个标志，指出线程应该活动还是挂起。若标志指出线程应该挂起，便用wait()命其进入等待状态。若标志指出线程应当恢复，则用一个notify()重新启动线程。jdk1.5后提供了condition对象，这个对象的await()和singal()方法也可以达到线程通信的效果。

二、wait和notify实例
子线程循环10次，主线程循环100次。接着子线程循环10次，主线程循环100次。如此循环50次。摘自张孝祥老师线程视频源码。
public class TraditionalThreadCommunication
{
public static void main(String[] args)
{
final Business business = new Business();
new Thread(new Runnable() {
public void run()
{
for (int i = 1; i <= 50; i++)
{
business.sub(i);
}
}
}).start();
for (int i = 1; i <= 50; i++)
{
business.main(i);
}
}
}

class Business
{
private boolean bShouldSub= true;

public synchronized void sub(int i)
{
while (!bShouldSub)
{
try
{
this.wait();
}
catch (InterruptedException e)
{
e.printStackTrace();
}
}
for (int j = 1; j <= 10; j++)
{
System.out.println("sub thread sequence of " + j + ",loop of " + i);
}
bShouldSub = false;
this.notify();
}

public synchronizedvoid main(int i)
{
while (bShouldSub)
{
try
{
this.wait();
}
catch (InterruptedException e)
{
e.printStackTrace();
}
}
for (int j = 1; j <= 100; j++)
{
System.out.println("main thread sequence of " + j + ",loop of " + i);
}
bShouldSub = true;
this.notify();
}
}

三、Condition实例
public class Condition1Test
{
public static void main(String[] args)
{
final BusinessLock business = new BusinessLock();
new Thread(new Runnable() {
public void run()
{
for (int i = 1; i <= 50; i++)
{
business.sub(i);
}
}
}).start();
for (int i = 1; i <= 50; i++)
{
business.main(i);
}
}
}

class BusinessLock
{
private boolean bShouldSub = true;

ReentrantLock lock = new ReentrantLock();
Condition condition = lock.newCondition();

public void sub(int i)
{
lock.lock();
try
{
while (!bShouldSub)
{
try
{
condition.await();
}
catch (InterruptedException e)
{
e.printStackTrace();
}
}
for (int j = 1; j <= 10; j++)
{
System.out.println("sub thread sequence of " + j + ",loop of " + i);
}
bShouldSub = false;
condition.signal();
}
finally
{
lock.unlock();
}
}

public void main(int i)
{
lock.lock();
try
{
while (bShouldSub)
{
try
{
condition.await();
}
catch (InterruptedException e)
{
e.printStackTrace();
}
}
for (int j = 1; j <= 100; j++)
{
System.out.println("main thread sequence of " + j + ",loop of " + i);
}
bShouldSub = true;
condition.signal();
}
finally
{
lock.unlock();
}
}
}

四、Condition实例扩展
三个线程相互通信，main循环100次，sub2循环10次，sub3循环10次。接着main循环100次，sub2循环10次，sub3循环10次。如此循环50次。
public class Condition2Test
{
public static void main(String[] args)
{
final BusinessLock2 business = new BusinessLock2();
new Thread(new Runnable() {
public void run()
{
for (int i = 1; i <= 50; i++)
{
business.main(i);
}
}
}).start();

new Thread(new Runnable() {
public void run()
{
for (int i = 1; i <= 50; i++)
{
business.sub2(i);
}
}
}).start();

new Thread(new Runnable() {
public void run()
{
for (int i = 1; i <= 50; i++)
{
business.sub3(i);
}
}
}).start();
}
}


class BusinessLock2
{
private int bShouldSub = 1;

ReentrantLock lock = new ReentrantLock();
Condition condition1 = lock.newCondition();
Condition condition2 = lock.newCondition();
Condition condition3 = lock.newCondition();

public void main(int i)
{
lock.lock();
try
{
while (bShouldSub != 1)
{
try
{
condition1.await();
}
catch (InterruptedException e)
{
e.printStackTrace();
}
}
for (int j = 1; j <= 100; j++)
{
System.out.println("main thread sequence of " + j + ",loop of " + i);
}
bShouldSub = 2;
condition2.signal();
}
finally
{
lock.unlock();
}
}

public void sub2(int i)
{
lock.lock();
try
{
while (bShouldSub != 2)
{
try
{
condition2.await();
}
catch (InterruptedException e)
{
e.printStackTrace();
}
}
for (int j = 1; j <= 10; j++)
{
System.out.println("sub2 thread sequence of " + j + ",loop of " + i);
}
bShouldSub = 3;
condition3.signal();
}
finally
{
lock.unlock();
}
}

public void sub3(int i)
{
lock.lock();
try
{
while (bShouldSub != 3)
{
try
{
condition3.await();
}
catch (InterruptedException e)
{
e.printStackTrace();
}
}
for (int j = 1; j <= 10; j++)
{
System.out.println("sub3 thread sequence of " + j + ",loop of " + i);
}
bShouldSub = 1;
condition1.signal();
}
finally
{
lock.unlock();
}
}
}
关键词：
Java线程
线程await
线程notify
线程通信
Java通信
it徐胖子
目录
相关文章
杨校
|
2天前
|
druid Java Maven
杨校老师课堂之java_关于如何下载jar包的教程
杨校老师课堂之java_关于如何下载jar包的教程
杨校
14 0
梦回故国楼台梦
|
2天前
|
安全 Java
JAVA多线程通信新解：wait()、notify()、notifyAll()的实用技巧
【6月更文挑战第20天】Java多线程中，`wait()`, `notify()`和`notifyAll()`用于线程通信。在生产者-消费者模型示例中，它们确保线程同步。`synchronized`保证安全，`wait()`在循环内防止虚假唤醒，`notifyAll()`避免唤醒单一线程问题。关键技巧包括：循环内调用`wait()`，优先使用`notifyAll()`以保证可靠性，以及确保线程安全和正确处理`InterruptedException`。
梦回故国楼台梦
13 0
梦回故国楼台梦
|
2天前
|
Java 程序员
从菜鸟到大神：JAVA多线程通信的wait()、notify()、notifyAll()之旅
【6月更文挑战第21天】Java多线程核心在于wait(), notify(), notifyAll()，它们用于线程间通信与同步，确保数据一致性。wait()让线程释放锁并等待，notify()唤醒一个等待线程，notifyAll()唤醒所有线程。这些方法在解决生产者-消费者问题等场景中扮演关键角色，是程序员从新手到专家进阶的必经之路。通过学习和实践，每个程序员都能在多线程编程的挑战中成长。
梦回故国楼台梦
17 6
一叶飘舟
|
1天前
|
Oracle Java 关系型数据库
面试知识点：notify是随机唤醒线程吗（唤醒线程顺序）？
面试知识点：notify是随机唤醒线程吗（唤醒线程顺序）？
一叶飘舟
8 0
梦回故国楼台梦
|
1天前
|
Java
Java Socket编程与多线程：提升客户端-服务器通信的并发性能
【6月更文挑战第21天】Java网络编程中，Socket结合多线程提升并发性能，服务器对每个客户端连接启动新线程处理，如示例所示，实现每个客户端的独立操作。多线程利用多核处理器能力，避免串行等待，提升响应速度。防止死锁需减少共享资源，统一锁定顺序，使用超时和重试策略。使用synchronized、ReentrantLock等维持数据一致性。多线程带来性能提升的同时，也伴随复杂性和挑战。
梦回故国楼台梦
10 0
杨校
|
2天前
|
Java 数据库连接 Spring
杨校老师课堂之Java EE框架SSM所需jar包下载
杨校老师课堂之Java EE框架SSM所需jar包下载
杨校
9 0
梦回故国楼台梦
|
2天前
|
安全 Java
深入解读JAVA多线程：wait()、notify()、notifyAll()的奥秘
【6月更文挑战第20天】JAVA多线程中，wait(), notify(), notifyAll()是Object类的关键同步机制。wait()让线程等待并释放锁，直到被notify()或notifyAll()唤醒或超时。它们必须在同步块中使用，持有锁的线程调用。notify()唤醒一个等待线程，notifyAll()唤醒所有。最佳实践包括：与synchronized结合，循环检查条件，避免循环内notify()，通常优先使用notifyAll()。
梦回故国楼台梦
10 0
游客pnral34kl5xba
|
1天前
|
安全 Java 程序员
Java多线程详解
Java多线程详解
游客pnral34kl5xba
13 3
游客pnral34kl5xba
|
1天前
|
缓存 安全 Java
Java线程面试题含答案
Java线程面试题含答案
游客pnral34kl5xba
11 2
众所周知
|
2天前
|
Java
并发编程的艺术：Java线程与锁机制探索
【6月更文挑战第21天】**并发编程的艺术：Java线程与锁机制探索** 在多核时代，掌握并发编程至关重要。本文探讨Java中线程创建（`Thread`或`Runnable`）、线程同步（`synchronized`关键字与`Lock`接口）及线程池（`ExecutorService`）的使用。同时，警惕并发问题，如死锁和饥饿，遵循最佳实践以确保应用的高效和健壮。
众所周知
8 2

热门文章

最新文章

  • 1
    案例分析｜线程池相关故障梳理&总结
  • 2
    Java多线程实战-实现多线程文件下载，支持断点续传、日志记录等功能
  • 3
    【JAVA】Java 中什么叫单例设计模式？请用 Java 写出线程安全的单例模式
  • 4
    Python并发编程：解析异步IO与多线程
  • 5
    【JAVA】线程的run()和start()有什么区别？
  • 6
    高级主题：Visual Basic 中的多线程和并发编程
  • 7
    高德地图爬虫实践：Java多线程并发处理策略
  • 8
    Python 多线程编程实战：threading 模块的最佳实践
  • 9
    Java多线程实战-CompletableFuture异步编程优化查询接口响应速度
  • 10
    JavaSE&多线程&线程池
  • 1
    Springboot启动的时候初始化的线程池默认配置tomcat
    33
  • 2
    SpringBoot实现多线程定时任务动态定时任务配置文件配置定时任务
    316
  • 3
    Python开启线程和线程池的方法
    26
  • 4
    【C/C++ 线程池设计思路】 深入探索线程池设计：任务历史记录的高效管理策略
    101
  • 5
    【Qt 底层之事件驱动系统】深入理解 Qt 事件机制：主事件循环与工作线程的交互探究，包括 QML 的视角
    300
  • 6
    【C++ 线程包裹类设计】跨平台C++线程包装类：属性设置与平台差异的全面探讨
    60
  • 7
    线程同步与IPC：单进程多线程环境下的选择与权衡
    82
  • 8
    【Linux 系统标准 进程资源】Linux 创建一个最基本的进程所需的资源分析,以及线程资源与之的差异
    143
  • 9
    【软件设计师备考 专题 】操作系统的内核（中断控制）、进程、线程概念
    92
  • 10
    【ffmpeg音视频同步】解决ffmpeg音视频中多线程之间的数据同步问题
    95

    • 相关课程

    更多
  • Java面试疑难点解析 - 面试技巧及语言基础
  • Java面试疑难点解析 - Java Web开发
  • Java面试疑难点解析 - 系统架构及项目设计
  • Java编程入门
  • Java面向对象编程
  • Java高级编程

    • 相关电子书

    更多
  • Spring Cloud Alibaba - 重新定义 Java Cloud-Native
  • The Reactive Cloud Native Arch
  • JAVA开发手册1.5.0

    • 相关实验场景

    更多
  • 阿里云平台上进行Java程序的编译与运行
  • 使用Java面向对象编写网络通信程序应用
  • 手动部署Java Web环境（Alibaba Cloud Linux 2）
  • 搭建Java Web开发环境（Anolis OS）
  • RocketMQ中使用Java客户端发送消息和消费的应用
    • 下一篇
    2024年阿里云免费云服务器及学生云服务器申请教程参考