Java多線程之線程虛假喚醒

---

本文目錄提綱

問(wèn)題：兩個(gè)線程對(duì)一個(gè)初始值為零的變量操作，實(shí)現(xiàn)一個(gè)線程加一，另一個(gè)線程減一，來(lái)十次。

問(wèn)題：四個(gè)線程對(duì)一個(gè)初始值為零的變量操作，實(shí)現(xiàn)兩個(gè)線程加一，另外兩個(gè)線程減一，來(lái)十次。

---

1. 兩個(gè)線程對(duì)一個(gè)初始值為零的變量操作，實(shí)現(xiàn)一個(gè)線程加一，另一個(gè)線程減一，來(lái)十次。

---

代碼實(shí)現(xiàn)：

class ShareData{private int number = 0;public synchronized void increment() throws InterruptedException { // 判斷if (number!=0){this.wait();} // 干活++number;System.out.println(Thread.currentThread().getName()+"\t"+number); // 通知喚醒this.notifyAll();}public synchronized void decrement() throws InterruptedException {if (number==0){this.wait();}--number;System.out.println(Thread.currentThread().getName()+"\t"+number);this.notifyAll();} }public class ThreadDemo2 {public static void main(String[] args) {ShareData sd = new ShareData();new Thread(()->{for (int i = 1; i <=10 ; i++) {try {sd.increment();} catch (InterruptedException e) {e.printStackTrace();}} },"A").start();new Thread(()->{for (int i = 1; i <=10 ; i++) {try {sd.decrement();} catch (InterruptedException e) {e.printStackTrace();}}},"B").start();} }

---

編譯結(jié)果：

多次測(cè)試，是沒(méi)有問(wèn)題的。

---

2. 問(wèn)題：四個(gè)線程對(duì)一個(gè)初始值為零的變量操作，實(shí)現(xiàn)兩個(gè)線程加一，另外兩個(gè)線程減一，來(lái)十次。

---

于是把上面的代碼，線程弄多兩個(gè)，運(yùn)行發(fā)現(xiàn)出現(xiàn)問(wèn)題。編譯結(jié)果如下：

---

通過(guò)閱讀文檔，發(fā)現(xiàn)：

As in the one argument version, interrupts and spurious wakeups are possible, and this method should always be used in a loop:

synchronized (obj) {while (<condition does not hold>)obj.wait();... // Perform action appropriate to condition}

即中斷和偽喚醒是可能的，并且這個(gè)方法應(yīng)該在while循環(huán)中使用

畫(huà)圖：

將上面代碼if換成while再執(zhí)行，發(fā)現(xiàn)沒(méi)有問(wèn)題，代碼如下：

class ShareData {private int number = 0;public synchronized void increment() throws InterruptedException { // 判斷while (number != 0) {this.wait();} // 干活++number;System.out.println(Thread.currentThread().getName() + "\t" + number); // 通知喚醒this.notifyAll();}public synchronized void decrement() throws InterruptedException {while (number == 0) {this.wait();}--number;System.out.println(Thread.currentThread().getName() + "\t" + number);this.notifyAll();} }public class ThreadDemo2 {public static void main(String[] args) {ShareData sd = new ShareData();new Thread(() -> {for (int i = 1; i <= 10; i++) {try {Thread.sleep(200);sd.increment();} catch (InterruptedException e) {e.printStackTrace();}}}, "A").start();new Thread(() -> {for (int i = 1; i <= 10; i++) {try {Thread.sleep(300); //模擬執(zhí)行其他代碼sd.decrement();} catch (InterruptedException e) {e.printStackTrace();}}}, "B").start();new Thread(() -> {for (int i = 1; i <= 10; i++) {try {Thread.sleep(400);sd.increment();} catch (InterruptedException e) {e.printStackTrace();}}}, "C").start();new Thread(() -> {for (int i = 1; i <= 10; i++) {try {Thread.sleep(500);sd.decrement();} catch (InterruptedException e) {e.printStackTrace();}}}, "D").start();} }

---

編譯結(jié)果：

---

使用Lock優(yōu)化

前置知識(shí)：

Condition factors out the Object monitor methods (wait, notify and notifyAll) into distinct objects to give the effect of having multiple wait-sets per object, by combining them with the use of arbitrary Lock implementations. Where a Lock replaces the use ofsynchronized methods and statements, a Condition replaces the use of the Object monitor methods.

---

優(yōu)化代碼：

import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock;class ShareData {private int number = 0;private Lock lock = new ReentrantLock();private Condition condition = lock.newCondition();public synchronized void increment() throws InterruptedException{lock.lock();try{while (number != 0) { // this.wait();condition.await();} // 干活++number;System.out.println(Thread.currentThread().getName() + "\t" + number); // 通知喚醒 // this.notifyAll();condition.signalAll();}catch (Exception e){e.printStackTrace();}finally {lock.unlock();}}public synchronized void decrement() throws InterruptedException{lock.lock();try{while (number == 0) { // this.wait();condition.await();} // 干活--number;System.out.println(Thread.currentThread().getName() + "\t" + number); // 通知喚醒 // this.notifyAll();condition.signalAll();}catch (Exception e){e.printStackTrace();}finally {lock.unlock();}}public class ThreadDemo2 {public static void main(String[] args) {ShareData sd = new ShareData();new Thread(() -> {for (int i = 1; i <= 10; i++) {try {Thread.sleep(200);sd.increment();} catch (InterruptedException e) {e.printStackTrace();}}}, "A").start();new Thread(() -> {for (int i = 1; i <= 10; i++) {try {Thread.sleep(300);sd.decrement();} catch (InterruptedException e) {e.printStackTrace();}}}, "B").start();new Thread(() -> {for (int i = 1; i <= 10; i++) {try {Thread.sleep(400);sd.increment();} catch (InterruptedException e) {e.printStackTrace();}}}, "C").start();new Thread(() -> {for (int i = 1; i <= 10; i++) {try {Thread.sleep(500);sd.decrement();} catch (InterruptedException e) {e.printStackTrace();}}}, "D").start();} }

總結(jié)

以上是生活随笔為你收集整理的Java多线程之线程虚假唤醒的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。