阻塞队列的应用 || 多线程的条件判断 一定要用while,而不要用 if
生活随笔
收集整理的這篇文章主要介紹了
阻塞队列的应用 || 多线程的条件判断 一定要用while,而不要用 if
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
ProdConsTradiDemo.java
package thread;import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock;/*** 初始值為0的變量,兩個線程交替操作,一個+1,一個-1,執行五輪* 1 線程 操作 資源類* 2 判斷 干活 通知* 3 防止虛假喚醒機制*/ public class ProdConsTradiDemo {public static void main(String[] args) {ShareData shareData = new ShareData();new Thread(() -> {for (int i = 0; i < 5; i++) {try {shareData.increment();} catch (Exception e) {e.printStackTrace();}}}, "Producer").start();new Thread(() -> {for (int i = 0; i < 5; i++) {try {shareData.decrement();} catch (Exception e) {e.printStackTrace();}}}, "Consumer").start();} }class ShareData {private int number = 0;private Lock lock = new ReentrantLock();private Condition condition = lock.newCondition();public void increment() throws InterruptedException {lock.lock();try {//1 判斷while (number != 0) {//等待,不能生產condition.await();}//2 干活number++;System.out.println(Thread.currentThread().getName() + "\t" + number);//3 通知喚醒condition.signalAll();} catch (Exception e) {e.printStackTrace();} finally {lock.unlock();}}public void decrement() throws InterruptedException {lock.lock();try {//1 判斷while (number == 0) {//等待,不能生產condition.await();}//2 干活number--;System.out.println(Thread.currentThread().getName() + "\t" + number);//3 通知喚醒condition.signalAll();} catch (Exception e) {e.printStackTrace();} finally {lock.unlock();}} }多線程的條件判斷 一定要用while,而不要用 if
《新程序員》:云原生和全面數字化實踐50位技術專家共同創作,文字、視頻、音頻交互閱讀總結
以上是生活随笔為你收集整理的阻塞队列的应用 || 多线程的条件判断 一定要用while,而不要用 if的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: Semaphore
- 下一篇: Synchronized和Lock有什么