Java并发编程的艺术学习笔记（五）
这种通信方式是利用volatile和synchronized的同步机制通过读/写共享变量来实现线程间通信的。当一个共享变量被修改后，同步机制能使其被其他线程看到，就好像一个线程把修改后的共享变量的值告诉另一个线程，这便在逻辑上实现了线程间的通信。
1.2 特点
这种通信方式无法指定接收线程，因为当共享变量被修改后，最先访问的另一线程的选择是随机的。总的来说，这种通信方式并不传送数据，而是在共享数据。
2. 等待/通知机制
2.1 等待/通知的相关方法
| 方法名称 | 作用 |
|---|---|
| wait() | 调用该方法的线程将进入线程的等待状态，只有等待另外线程的通知或中断才能从该方法返回。此外，调用该方法后会释放对象锁 |
| wait(long) | 该方法是wait()方法的超时等待版本。即在long毫秒时间内作用和wait()方法一致，在超过long时间后若还没被通知或中断，则直接返回。 |
| notify() | 通知另外一个在对象上等待的线程，令其从wait()方法返回。调用该方法的线程需先获得对象锁。 |
| notifyAll() | 通知另外所有在对象上等待的线程，令他们从wait()方法返回。调用该方法的线程需先获得对象锁。 |
2.2 等待/通知机制的理解
等待通知机制，是指一个线程A调用了某一对象O的wait()方法后进入线程的等待状态。另外一个线程B调用了对象O的notify()或notifyAll()方法后，线程A从wait()方法返回。上述两个线程是通过同一个对象O来实现交互的。
2.3 等待/通知机制的注意事项
●调用wait()、notify()或notify()方法前需先获得对象的锁。
●调用wait()方法的线程将进入线程的等待状态，并且被放置到等待队列中，同时释放对象锁。
●另一线程调用notify()方法后，等待队列中的一个线程将由等待状态转变为阻塞状态，并且被移动到同步队列中。同理notifyAll()方法操作的是等待队列中所有的线程。
●当线程调用notify()或notifyAll()方法后，另一线程并不会立即从wait()方法返回，而是需要调用notify()或notifyAll()的线程释放对象锁后才有机会从wait()方法返回。
●从wait()方法返回的前提是获得对象锁。
2.4 等待/通知机制的经典范式
●等待方:
synchronized(对象O) {
while(条件不成立) {
O.wait();
}
相应的处理逻辑;
}
复制代码
●通知方:
synchronized(对象O) {
修改条件使得上述等待方的条件成立;
O.notify()或O.notifyAll();
}
复制代码
3. 管道输入/输出流
●管道输入/输出流主要用处线程之间的数据传输，而传输的媒介为内存。
●管道输入/输出流的四种实现:PipedInputstream、PipedOutputStream、PipedWriter、PipedReader。前两种面向字节，后两种面向字符。
●管道的输入流和输出流在使用时需要进行连接，也就是调用connect()方法，否则会抛出IOException异常。
4. Thread.join()的使用
●当一个线程A执行了thread.join()时(底层调用wait()方法)，表示让线程A等待线程thread执行完毕后再从join()方法返回线程A继续执行。
●除了join()方法外，还有join(long millis)和join(long millis，int nanos)这两个具备超时返回特性的方法。
●join()能让多条并发执行的线程串行执行。
●因调用join()方法而处于等待状态的线程可被其Thread.interrput()方法中断。
正文到此结束
热门推荐
相关文章
近期评论
-
666
-
文章和留言都翻到11页了 没有OOM
-
-
朋友，翻页到11页，及以后，会出现OOM，无法访问
-
-
-
-
版本号是多少，你可以下载哪个代码仓库，jdk选1.8 直接跑就行
-
-
Loading...
![[HBLOG]公众号](https://www.liuhaihua.cn/img/qrcode_gzh.jpg)
