賣票案例:解決執行緒安全問題,Lock鎖
阿新 • • 發佈:2020-11-13
package com.chunzhi.Test09Lock; /* 模擬賣票案例 建立3個執行緒,同時開啟,對共享的票進行出售 */ public class Test01Ticket { public static void main(String[] args) { // 建立Runnable介面的實現類物件 RunnableImpl3 run = new RunnableImpl3(); // 建立Thread類物件,構造方法中傳遞Runnable介面的實現類物件 Thread t1 = new Thread(run); Thread t2= new Thread(run); Thread t3 = new Thread(run); // 呼叫start方法開啟多執行緒 t1.start(); t2.start(); t3.start(); } }
package com.chunzhi.Test09Lock; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; /* 解決執行緒安全問題的第三種方案:使用Lock鎖 java.util.concurrent.locks.Lock介面 Lock實現提供了比使用synchronized方法和語句可獲得的更廣泛的鎖定操作。 Lock介面中的方法: void lock()獲取鎖 void unlock() 釋放鎖 java.util.concurrent.locks.ReentrantLock implements Lock介面 使用步驟: 1.在成員位置建立一個ReentrantLock物件 2.在可能會出現安全問題的程式碼前呼叫Lock介面中的方法lock獲取鎖 3.在可能會出現安全問題的程式碼後呼叫Lock介面中的方法unlock釋放鎖*/ public class RunnableImpl3 implements Runnable { // 定義一個多執行緒共享的票源 private int ticket = 100; // 現在多核多執行緒計算的CPU太快了,這裡可以適當調更大的值 // 1.在成員位置建立一個ReentrantLock物件 Lock l = new ReentrantLock(); // 設定執行緒任務:賣票 @Override public void run() { // 使用死迴圈,讓賣票操作重複執行 while (true) {// 2.在可能會出現安全問題的程式碼前呼叫Lock介面中的方法lock獲取鎖 l.lock(); // 先判斷票是否存在 if (ticket > 0) { // 有票,賣票 System.out.println(Thread.currentThread().getName() + "正在賣第" + ticket + "張票"); // 賣一次票減一張票 ticket--; } // 3.在可能會出現安全問題的程式碼後呼叫Lock介面中的方法unlock釋放鎖 l.unlock(); } } }