您好,登錄后才能下訂單哦!
今天小編給大家分享一下Java中的synchronized關鍵字怎么使用的相關知識點,內容詳細,邏輯清晰,相信大部分人都還太了解這方面的知識,所以分享這篇文章給大家參考一下,希望大家閱讀完這篇文章后有所收獲,下面我們一起來了解一下吧。
要使方法同步,只需將synchronized關鍵字添加到其聲明中:
public class SynchronizedDemo { private int i = 0; public synchronized void add() { i++; } public synchronized void del() { i--; } public synchronized int getValue() { return i; } }
如上代碼顯示,一共有三個同步方法:
add()
del()
getValue()
每個方法同一個對象同一時刻只會被調用一次,比如一個線程在調用add()時,其他線程都會被阻塞,直到第一個線程處理完add()方法。
public void del(int value){ synchronized(this){ this.i -= value; } }
如上代碼,synchronized加在了一個{}代碼前,這個就代表是一個同步代碼塊。
同步是一個控制多個線程訪問任何共享資源的進程,可以避免不一致的結果。使用同步的主要目的是避免線程的不一致行為,防止線程干擾。
在java中可以使用synchronized 關鍵字實現同步的效果,synchronized只能應用于方法和塊,不能應用于變量和類。
首先我們來看一段代碼:
public class SynchronizedDemo { int i; public void increment() { i++; } public static void main(String[] args) { SynchronizedDemo synchronizedDemo = new SynchronizedDemo(); synchronizedDemo.increment(); System.out.println("計算值為:" + synchronizedDemo.i); } }
每當調用increment()方法時計算值都會加1:
調用2次就會加2,調用3次就會加3,調用4次就會加4:
public class SynchronizedDemo { int i; public void increment() { i++; } public static void main(String[] args) { SynchronizedDemo synchronizedDemo = new SynchronizedDemo(); synchronizedDemo.increment(); synchronizedDemo.increment(); synchronizedDemo.increment(); synchronizedDemo.increment(); System.out.println("計算值為:" + synchronizedDemo.i); } }
現在我們擴展一下上面的例子,創建一個線程去調用10次increment()方法:
public class SynchronizedDemo { int i; public void increment() { i++; } public static void main(String[] args) { SynchronizedDemo synchronizedDemo = new SynchronizedDemo(); Thread thread = new Thread(() -> { for (int i = 1; i <= 10; i++) { synchronizedDemo.increment(); } }); thread.start(); try { thread.join(); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("計算值為:" + synchronizedDemo.i); } }
此時計算的結果正如我們預料的那樣,結果為10.
這是單線程的情況,一切都是如此的美好,但是事實真的如此嗎?如果是多線程環境,會是什么樣的?
下面我們來演示一下多線程的情況!
public class SynchronizedDemo { int i; public void increment() { i++; } public static void main(String[] args) { SynchronizedDemo synchronizedDemo = new SynchronizedDemo(); Thread thread1 = new Thread(() -> { for (int i = 1; i <= 1000; i++) { synchronizedDemo.increment(); } }); Thread thread2 = new Thread(() -> { for (int i = 1; i <= 1000; i++) { synchronizedDemo.increment(); } }); thread1.start(); thread2.start(); try { thread1.join(); thread2.join(); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("計算值為:" + synchronizedDemo.i); } }
如上代碼,我們創建了兩個線程 thread1 和 thread2,每個線程調用1000次increment(),理論上最終打印的值應該是2000,因為thread1調用increment()1000次后值會變成1000,thread2調用increment()1000次后值會變成2000.
我們執行一下,看看結果:
結果和我們想的不一樣,小于2000,我們再執行一下:
結果還是小于2000.
這是為什么呢?
因為多線程支持并行處理,因此,兩個線程總是有可能同時獲取計數器的值,因此都得到相同的計數器值,所以在這種情況下,不是遞增計數器的值兩次,只增加一次。
那么,如何避免這種情況呢?
使用 synchronized 關鍵字即可解決。
我們只需要將increment()方法加上synchronized就可以了:
public class SynchronizedDemo { int i; public synchronized void increment() { i++; } public static void main(String[] args) { SynchronizedDemo synchronizedDemo = new SynchronizedDemo(); Thread thread1 = new Thread(() -> { for (int i = 1; i <= 1000; i++) { synchronizedDemo.increment(); } }); Thread thread2 = new Thread(() -> { for (int i = 1; i <= 1000; i++) { synchronizedDemo.increment(); } }); thread1.start(); thread2.start(); try { thread1.join(); thread2.join(); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("計算值為:" + synchronizedDemo.i); } }
這個時候我們再執行一下:
可以看到,值為2000.
我們把計算次數提高到10000次:
public class SynchronizedDemo { int i; public synchronized void increment() { i++; } public static void main(String[] args) { SynchronizedDemo synchronizedDemo = new SynchronizedDemo(); Thread thread1 = new Thread(() -> { for (int i = 1; i <= 10000; i++) { synchronizedDemo.increment(); } }); Thread thread2 = new Thread(() -> { for (int i = 1; i <= 10000; i++) { synchronizedDemo.increment(); } }); thread1.start(); thread2.start(); try { thread1.join(); thread2.join(); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("計算值為:" + synchronizedDemo.i); } }
執行結果為:
可以看出,一個小小的synchronized竟然那么簡單的就解決了這個問題。
這個背后的原理就是線程1執行increment()方法時,因為有synchronized,所以會自動將此方法加鎖,而此時只有線程1擁有這把鎖,其他線程只能等待,直到線程1釋放這把鎖,線程2才能參與調用。
同理,當線程2去調用increment()時,線程2拿到鎖,線程1進入等待,直到線程2釋放鎖,就這樣,直到計算完畢,在此過程中,不會出現計算錯誤的情況。
以上就是“Java中的synchronized關鍵字怎么使用”這篇文章的所有內容,感謝各位的閱讀!相信大家閱讀完這篇文章都有很大的收獲,小編每天都會為大家更新不同的知識,如果還想學習更多的知識,請關注億速云行業資訊頻道。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。