解決方法三：lock鎖機制

trigkit4 發(fā)布于2019-08-19 10:12 / 3436人閱讀

摘要：賣票案例出現(xiàn)了線程安全問題賣出了不存在的票和重復(fù)的票解決線程安全問題的三種方案使用鎖接口實現(xiàn)提供了比使用方法和語句可獲得的更廣泛的鎖定操作。接口中的方法獲取鎖。

package com.itheima.demo09.Lock;

import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

賣票案例出現(xiàn)了線程安全問題
賣出了不存在的票和重復(fù)的票

解決線程安全問題的三種方案:使用Lock鎖
java.util.concurrent.locks.Lock接口
Lock 實現(xiàn)提供了比使用 synchronized 方法和語句可獲得的更廣泛的鎖定操作。
Lock接口中的方法:
    void lock()獲取鎖。
    void unlock()  釋放鎖。
java.util.concurrent.locks.ReentrantLock implements Lock接口


使用步驟:
    1.在成員位置創(chuàng)建一個ReentrantLock對象
    2.在可能會出現(xiàn)安全問題的代碼前調(diào)用Lock接口中的方法lock獲取鎖
    3.在可能會出現(xiàn)安全問題的代碼后調(diào)用Lock接口中的方法unlock釋放鎖

*/
public class RunnableImpl implements Runnable{

//定義一個多個線程共享的票源
private  int ticket = 100;

//1.在成員位置創(chuàng)建一個ReentrantLock對象
Lock l = new ReentrantLock();

//設(shè)置線程任務(wù):賣票
@Override
public void run() {
    //使用死循環(huán),讓賣票操作重復(fù)執(zhí)行
    while(true){
        //2.在可能會出現(xiàn)安全問題的代碼前調(diào)用Lock接口中的方法lock獲取鎖
        l.lock();

        //先判斷票是否存在
        if(ticket>0){
            //提高安全問題出現(xiàn)的概率,讓程序睡眠
            try {
                Thread.sleep(10);
                //票存在,賣票 ticket--
                System.out.println(Thread.currentThread().getName()+"-->正在賣第"+ticket+"張票");
                ticket--;
            } catch (InterruptedException e) {
                e.printStackTrace();
            }finally {
                //3.在可能會出現(xiàn)安全問題的代碼后調(diào)用Lock接口中的方法unlock釋放鎖
                l.unlock();//無論程序是否異常,都會把鎖釋放
            }
        }
    }
}

/*//設(shè)置線程任務(wù):賣票
@Override
public void run() {
    //使用死循環(huán),讓賣票操作重復(fù)執(zhí)行
    while(true){
       //2.在可能會出現(xiàn)安全問題的代碼前調(diào)用Lock接口中的方法lock獲取鎖
       l.lock();

        //先判斷票是否存在
        if(ticket>0){
            //提高安全問題出現(xiàn)的概率,讓程序睡眠
            try {
                Thread.sleep(10);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

            //票存在,賣票 ticket--
            System.out.println(Thread.currentThread().getName()+"-->正在賣第"+ticket+"張票");
            ticket--;
        }

        //3.在可能會出現(xiàn)安全問題的代碼后調(diào)用Lock接口中的方法unlock釋放鎖
        l.unlock();
    }
}*/

}
package com.itheima.demo09.Lock;

模擬賣票案例
創(chuàng)建3個線程,同時開啟,對共享的票進行出售

*/
public class Demo01Ticket {

public static void main(String[] args) {
    //創(chuàng)建Runnable接口的實現(xiàn)類對象
    RunnableImpl run = new RunnableImpl();
    //創(chuàng)建Thread類對象,構(gòu)造方法中傳遞Runnable接口的實現(xiàn)類對象
    Thread t0 = new Thread(run);
    Thread t1 = new Thread(run);
    Thread t2 = new Thread(run);
    //調(diào)用start方法開啟多線程
    t0.start();
    t1.start();
    t2.start();
}

}