欢迎大家关注我的公众号,会不定期更新一些开发与测试的一些技术文章。
往期回顾...
synchronized的各种骚操作骚要点-对象锁、类锁、this锁、非this锁等
1、java线程间通信内部实现简述
在命令式编程中,线程之间的通信机制有两种:共享内存和消息传递。 而Java采用的共享内存模型,线程之间共享程序的公共状态,通过写-读内存中的公共状态进行隐式通信。是由Java内存模型控制,该模型决定一个线程对共享变量的写入何时对另一个线程可见。
结合上图,了解下Java的线程间的通信机制。
前面我们说到,Java线程间的通信由java内存模型控制,从抽象的角度来看,该模型定义了线程和主内存之间的抽象关系:线程之间的共享变量存储在主内存(Main Memory)中,每个线程都有一个私有的本地工作内存,本地工作内存中存储了该线程以读/写共享变量的副本。本地工作内存是Java内存模型的一个抽象概念,并不真实存在。它涵盖了缓存、写缓冲区、寄存器以及其他的硬件和编译器优化。
注:在消息传递的并发模型里,线程之间没有公共状态,线程之间必须通过发送消息来显式进行通信。
2、线程间通信知识点讲解与示例代码
2.1、等待/通知机制
等待/通知机制可以用来实现生产者/消费者模式(后面会单独介绍)。
2.1.1、synchronized与wait()和notify()方法的使用
2.1.1.1、要点
<1、wait()方法使线程停止运行并等待,notify()使等待的线程继续运行。
<2、wait()方法的作用是使当前执行代码的线程进行等待,该方法会将当前线程放入等待队列中,直到接到通知或被中断为止。
<3、notify()方法的作用是通知可能等待锁的线程,如果有多个线程,则随机选一个呈wait状态的线程,对其进行唤醒,使其获得锁。
<4、执行notify()方法后,需要notify()方法所在的同步代码块中的程序执行完后,当前线程才会释放锁,而wait状态的线程才会获得锁。
<5、使用wait()和notify()方法必须获得正确的锁,不然会抛出IllegalMonitorStateException异常。如下图的wait()方法,notify请自行实验:
2.1.1.2、示例代码:
图1:
图1中testWait和testNotify两个方法被synchronized修饰,都是持有的该对象的对象锁,并在调用wait和notify方法前分别打印提示和当前线程名。(关于synchronized的详细内容,见synchronized的各种骚操作骚要点-对象锁、类锁、this锁、非this锁等)
图2:
图2中的线程为调用wait()方法的线程类,实现Runnable接口,并在构造方法中传入Service对象,run方法中调用testWait方法。
图3:
图3和图2类似,只是run方法中调用的是testNotify方法。
图4:
欢迎大家关注我的公众号,会不定期更新一些开发与测试的一些技术文章。