這篇文章主要介紹怎么實現Java線程安全問題,文中介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們一定要看完!
這篇文章主要介紹了如何實現Java線程安全問題,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
解決線程安全問題的第一種方案:使用同步代碼塊
格式:
synchronized(鎖對象) {
可能會出現線程安全問題的代碼(訪問了共享數據的代碼)
}
注意:代碼塊中的鎖對象,可以是任意對象,但必須保證多個線程之間使用的是同一個
鎖對象的作用是把同步代碼塊鎖住,同一時間只能讓一個線程在同步代碼塊中執行
package com.fgy.demo02;/** * 實現賣票案例 */public class RunnableImpl implements Runnable { private int ticket = 100; Object obj = new Object(); @Override public void run() { while (true) { synchronized (obj) { if (ticket > 0) { try { Thread.sleep(100); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(Thread.currentThread().getName() + "正在買第" + ticket + "張票"); ticket--; } } } }}
package com.fgy.demo02;public class Demo01Ticket { public static void main(String[] args) { RunnableImpl run = new RunnableImpl(); new Thread(run).start(); new Thread(run).start(); new Thread(run).start(); }}
解決線程安全問題的第二種方案:使用同步方法
使用步驟:
1.把訪問了共享數據的代碼抽取出來,放到一個方法中
2.在方法上添加synchronized修飾符
格式:
修飾符 synchronized 返回值類型 方法名(...) {
可能會出現線程安全問題的代碼(訪問了共享數據的代碼)
}
同步方法的鎖對象是:this
靜態同步方法的鎖對象不能是this,因為this是創建對象后產生的,靜態方法優先于對象
靜態方法的鎖對象是本類的class文件對象
package com.fgy.demo03;/** * 實現賣票案例 */public class RunnableImpl implements Runnable { private int ticket = 100; @Override public void run() { while (true) { payTicket(); } } public synchronized void payTicket() { if (ticket > 0) { try { Thread.sleep(100); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(Thread.currentThread().getName() + "正在買第" + ticket + "張票"); ticket--; } }}
解決線程安全問題的第三種方案:使用lock鎖
使用步驟:
1.在成員位置創建ReenterantLock對象
2.在可能出現安全問題的代碼前調用Lock接口中的方法lock()獲取鎖
3.在可能出現安全問題的代碼后調用Lock接口中的方法unlock()釋放鎖
package com.fgy.demo04;import java.util.concurrent.locks.Lock;import java.util.concurrent.locks.ReentrantLock;/** * 實現賣票案例 */public class RunnableImpl implements Runnable { private int ticket = 100; Lock l = new ReentrantLock(); /*@Override public void run() { while (true) { l.lock(); if (ticket > 0) { try { Thread.sleep(100); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(Thread.currentThread().getName() + "正在買第" + ticket + "張票"); ticket--; } l.unlock(); } }*/ @Override public void run() { while (true) { l.lock(); if (ticket > 0) { try { Thread.sleep(100); System.out.println(Thread.currentThread().getName() + "正在買第" + ticket + "張票"); ticket--; } catch (InterruptedException e) { e.printStackTrace(); } finally { // 無論程序是否發生異常都會釋放鎖 l.unlock(); } } } }}
以上是“怎么實現Java線程安全問題”這篇文章的所有內容,感謝各位的閱讀!希望分享的內容對大家有幫助,更多相關知識,歡迎關注億速云行業資訊頻道!
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。