国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 編程 > Java > 正文

Java多線程程序中synchronized修飾方法的使用實例

2019-11-26 14:11:06
字體:
來源:轉載
供稿:網友

在Java 5以前,是用synchronized關鍵字來實現鎖的功能。

synchronized關鍵字可以作為方法的修飾符(同步方法),也可作用于函數內的語句(同步代碼塊)。

掌握synchronized,關鍵是要掌握把那個東西作為鎖。對于類的非靜態方法(成員方法)而言,意味著要取得對象實例的鎖;對于類的靜態方法(類方法)而言,要取得類的Class對象的鎖;對于同步代碼塊,要指定取得的是哪個對象的鎖。同步非靜態方法可以視為包含整個方法的synchronized(this) { … }代碼塊。   

不管是同步代碼塊還是同步方法,每次只有一個線程可以進入(在同一時刻最多只有一個線程執行該段代碼。),如果其他線程試圖進入(不管是同一同步塊還是不同的同步塊),jvm會將它們掛起(放入到等鎖池中)。這種結構在并發理論中稱為臨界區(critical section)。

在jvm內部,為了提高效率,同時運行的每個線程都會有它正在處理的數據的緩存副本,當我們使用synchronzied進行同步的時候,真正被同步的是在不同線程中表示被鎖定對象的內存塊(副本數據會保持和主內存的同步,現在知道為什么要用同步這個詞匯了吧),簡單的說就是在同步塊或同步方法執行完后,對被鎖定的對象做的任何修改要在釋放鎖之前寫回到主內存中;在進入同步塊得到鎖之后,被鎖定對象的數據是從主內存中讀出來的,持有鎖的線程的數據副本一定和主內存中的數據視圖是同步的 。

下面舉具體的例子來說明synchronized的各種情況。

synchronized同步方法

首先來看同步方法的例子:

public class SynchronizedTest1 extends Thread {   private synchronized void testSynchronizedMethod()   {     for (int i = 0; i < 10; i++)     {       System.out.println(Thread.currentThread().getName()           + " testSynchronizedMethod:" + i);        try       {         Thread.sleep(100);       }       catch (InterruptedException e)       {         e.printStackTrace();       }     }   }    @Override   public void run()   {     testSynchronizedMethod();   }    public static void main(String[] args)   {          SynchronizedTest1 t = new SynchronizedTest1();     t.start();     t.testSynchronizedMethod();   } } 

運行該程序輸出結果為:

main testSynchronizedMethod:0 main testSynchronizedMethod:1 main testSynchronizedMethod:2 main testSynchronizedMethod:3 main testSynchronizedMethod:4 main testSynchronizedMethod:5 main testSynchronizedMethod:6 main testSynchronizedMethod:7 main testSynchronizedMethod:8 main testSynchronizedMethod:9 Thread-0 testSynchronizedMethod:0 Thread-0 testSynchronizedMethod:1 Thread-0 testSynchronizedMethod:2 Thread-0 testSynchronizedMethod:3 Thread-0 testSynchronizedMethod:4 Thread-0 testSynchronizedMethod:5 Thread-0 testSynchronizedMethod:6 Thread-0 testSynchronizedMethod:7 Thread-0 testSynchronizedMethod:8 Thread-0 testSynchronizedMethod:9 

可以看到testSynchronizedMethod方法在兩個線程之間同步執行。

如果此時將main方法修改為如下所示,則兩個線程并不能同步執行,因為此時兩個線程的同步監視器不是同一個對象,不能起到同步的作用。

public static void main(String[] args)   {     Thread t = new SynchronizedTest1();     t.start();          Thread t1 = new SynchronizedTest1();     t1.start();   } 

此時輸出結果如下所示:

Thread-0 testSynchronizedMethod:0 Thread-1 testSynchronizedMethod:0 Thread-0 testSynchronizedMethod:1 Thread-1 testSynchronizedMethod:1 Thread-0 testSynchronizedMethod:2 Thread-1 testSynchronizedMethod:2 Thread-0 testSynchronizedMethod:3 Thread-1 testSynchronizedMethod:3 Thread-0 testSynchronizedMethod:4 Thread-1 testSynchronizedMethod:4 Thread-0 testSynchronizedMethod:5 Thread-1 testSynchronizedMethod:5 Thread-0 testSynchronizedMethod:6 Thread-1 testSynchronizedMethod:6 Thread-0 testSynchronizedMethod:7 Thread-1 testSynchronizedMethod:7 Thread-0 testSynchronizedMethod:8 Thread-1 testSynchronizedMethod:8 Thread-0 testSynchronizedMethod:9 Thread-1 testSynchronizedMethod:9 

若想修改后的main方法能夠在兩個線程之間同步運行,需要將testSynchronizedMethod方法聲明為靜態方法,這樣兩個線程的監視器是同一個對象(類對象),能夠同步執行。修改后的代碼如下所示:

public class SynchronizedTest1 extends Thread {   private static synchronized void testSynchronizedMethod()   {     for (int i = 0; i < 10; i++)     {       System.out.println(Thread.currentThread().getName()           + " testSynchronizedMethod:" + i);        try       {         Thread.sleep(100);       }       catch (InterruptedException e)       {         e.printStackTrace();       }     }   }    @Override   public void run()   {     testSynchronizedMethod();   }    public static void main(String[] args)   {     Thread t = new SynchronizedTest1();     t.start();          Thread t1 = new SynchronizedTest1();     t1.start();   } } 

輸出結果如下:

Thread-0 testSynchronizedMethod:0 Thread-0 testSynchronizedMethod:1 Thread-0 testSynchronizedMethod:2 Thread-0 testSynchronizedMethod:3 Thread-0 testSynchronizedMethod:4 Thread-0 testSynchronizedMethod:5 Thread-0 testSynchronizedMethod:6 Thread-0 testSynchronizedMethod:7 Thread-0 testSynchronizedMethod:8 Thread-0 testSynchronizedMethod:9 Thread-1 testSynchronizedMethod:0 Thread-1 testSynchronizedMethod:1 Thread-1 testSynchronizedMethod:2 Thread-1 testSynchronizedMethod:3 Thread-1 testSynchronizedMethod:4 Thread-1 testSynchronizedMethod:5 Thread-1 testSynchronizedMethod:6 Thread-1 testSynchronizedMethod:7 Thread-1 testSynchronizedMethod:8 Thread-1 testSynchronizedMethod:9 

同步塊的情況與同步方法類似,只是同步塊將同步控制的粒度縮小,這樣能夠更好的發揮多線程并行執行的效率。
使用this對象控制同一對象實例之間的同步:

public class SynchronizedTest2 extends Thread {   private void testSynchronizedBlock()   {     synchronized (this)     {       for (int i = 0; i < 10; i++)       {         System.out.println(Thread.currentThread().getName()             + " testSynchronizedBlock:" + i);          try         {           Thread.sleep(100);         }         catch (InterruptedException e)         {           e.printStackTrace();         }       }     }   }    @Override   public void run()   {     testSynchronizedBlock();   }    public static void main(String[] args)   {     SynchronizedTest2 t = new SynchronizedTest2();     t.start();      t.testSynchronizedBlock();   } } 

輸出結果:

main testSynchronizedBlock:0 main testSynchronizedBlock:1 main testSynchronizedBlock:2 main testSynchronizedBlock:3 main testSynchronizedBlock:4 main testSynchronizedBlock:5 main testSynchronizedBlock:6 main testSynchronizedBlock:7 main testSynchronizedBlock:8 main testSynchronizedBlock:9 Thread-0 testSynchronizedBlock:0 Thread-0 testSynchronizedBlock:1 Thread-0 testSynchronizedBlock:2 Thread-0 testSynchronizedBlock:3 Thread-0 testSynchronizedBlock:4 Thread-0 testSynchronizedBlock:5 Thread-0 testSynchronizedBlock:6 Thread-0 testSynchronizedBlock:7 Thread-0 testSynchronizedBlock:8 Thread-0 testSynchronizedBlock:9 

使用class對象控制不同實例之間的同步:

public class SynchronizedTest2 extends Thread {   private void testSynchronizedBlock()   {     synchronized (SynchronizedTest2.class)     {       for (int i = 0; i < 10; i++)       {         System.out.println(Thread.currentThread().getName()             + " testSynchronizedBlock:" + i);          try         {           Thread.sleep(100);         }         catch (InterruptedException e)         {           e.printStackTrace();         }       }     }   }    @Override   public void run()   {     testSynchronizedBlock();   }    public static void main(String[] args)   {     Thread t = new SynchronizedTest2();     t.start();      Thread t2 = new SynchronizedTest2();     t2.start();   } } 

輸出結果:

Thread-0 testSynchronizedBlock:0 Thread-0 testSynchronizedBlock:1 Thread-0 testSynchronizedBlock:2 Thread-0 testSynchronizedBlock:3 Thread-0 testSynchronizedBlock:4 Thread-0 testSynchronizedBlock:5 Thread-0 testSynchronizedBlock:6 Thread-0 testSynchronizedBlock:7 Thread-0 testSynchronizedBlock:8 Thread-0 testSynchronizedBlock:9 Thread-1 testSynchronizedBlock:0 Thread-1 testSynchronizedBlock:1 Thread-1 testSynchronizedBlock:2 Thread-1 testSynchronizedBlock:3 Thread-1 testSynchronizedBlock:4 Thread-1 testSynchronizedBlock:5 Thread-1 testSynchronizedBlock:6 Thread-1 testSynchronizedBlock:7 Thread-1 testSynchronizedBlock:8 Thread-1 testSynchronizedBlock:9 

 
使用synchronized關鍵字進行同步控制時,一定要把握好對象監視器,只有獲得監視器的進程可以運行,其它都需要等待獲取監視器。任何一個非null的對象都可以作為對象監視器,當synchronized作用在方法上時,鎖住的便是對象實例(this);當作用在靜態方法時鎖住的便是對象對應的Class實例

兩個線程同時訪問一個對象的同步方法
當兩個并發線程訪問同一個對象的同步方法時,只能有一個線程得到執行。另一個線程必須等待當前線程執行完這個以后才能執行。

public class TwoThread {  public static void main(String[] args) {    final TwoThread twoThread = new TwoThread();    Thread t1 = new Thread(new Runnable() {      public void run() {        twoThread.syncMethod();      }    }, "A");    Thread t2 = new Thread(new Runnable() {      public void run() {        twoThread.syncMethod();      }    }, "B");    t1.start();    t2.start();  }  public synchronized void syncMethod() {    for (int i = 0; i < 5; i++) {      System.out.println(Thread.currentThread().getName() + " : " + i);      try {        Thread.sleep(500);      } catch (InterruptedException ie) {      }    }  }}

輸出結果:

A : 0A : 1A : 2A : 3A : 4B : 0B : 1B : 2B : 3B : 4

兩個線程訪問的是兩個對象的同步方法
這種情況下,synchronized不起作用,跟普通的方法一樣。因為對應的鎖是各自的對象。

public class TwoObject {  public static void main(String[] args) {    final TwoObject object1 = new TwoObject();    Thread t1 = new Thread(new Runnable() {      public void run() {        object1.syncMethod();      }    }, "Object1");    t1.start();    final TwoObject object2 = new TwoObject();    Thread t2 = new Thread(new Runnable() {      public void run() {        object2.syncMethod();      }    }, "Object2");    t2.start();  }  public synchronized void syncMethod() {    for (int i = 0; i < 5; i++) {      System.out.println(Thread.currentThread().getName() + " : " + i);      try {        Thread.sleep(500);      } catch (InterruptedException ie) {      }    }  }}

其中一種可能的輸出結果:

Object2 : 0Object1 : 0Object1 : 1Object2 : 1Object2 : 2Object1 : 2Object2 : 3Object1 : 3Object1 : 4Object2 : 4

兩個線程訪問的是synchronized的靜態方法
這種情況,由于鎖住的是Class,在任何時候,該靜態方法只有一個線程可以執行。

同時訪問同步方法與非同步方法
當一個線程訪問對象的一個同步方法時,另一個線程仍然可以訪問該對象中的非同步方法。

public class SyncAndNoSync {  public static void main(String[] args) {    final SyncAndNoSync syncAndNoSync = new SyncAndNoSync();    Thread t1 = new Thread(new Runnable() {      public void run() {        syncAndNoSync.syncMethod();      }    }, "A");    t1.start();    Thread t2 = new Thread(new Runnable() {      public void run() {        syncAndNoSync.noSyncMethod();      }    }, "B");    t2.start();  }  public synchronized void syncMethod() {    for (int i = 0; i < 5; i++) {      System.out.println(Thread.currentThread().getName() + " at syncMethod(): " + i);      try {        Thread.sleep(500);      } catch (InterruptedException ie) {      }    }  }  public void noSyncMethod() {    for (int i = 0; i < 5; i++) {      System.out.println(Thread.currentThread().getName() + " at noSyncMethod(): " + i);      try {        Thread.sleep(500);      } catch (InterruptedException ie) {      }    }  }}

一種可能的輸出結果:

B at noSyncMethod(): 0A at syncMethod(): 0B at noSyncMethod(): 1A at syncMethod(): 1B at noSyncMethod(): 2A at syncMethod(): 2B at noSyncMethod(): 3A at syncMethod(): 3A at syncMethod(): 4B at noSyncMethod(): 4

訪問同一個對象的不同同步方法
當一個線程訪問一個對象的同步方法A時,其他線程對該對象中所有其它同步方法的訪問將被阻塞。因為第一個線程已經獲得了對象鎖,其他線程得不到鎖,則雖然是訪問不同的方法,但是沒有獲得鎖,也無法訪問。

public class TwoSyncMethod {  public static void main(String[] args) {    final TwoSyncMethod twoSyncMethod = new TwoSyncMethod();    Thread t1 = new Thread(new Runnable() {      public void run() {        twoSyncMethod.syncMethod1();      }    }, "A");    t1.start();    Thread t2 = new Thread(new Runnable() {      public void run() {        twoSyncMethod.syncMethod2();      }    }, "B");    t2.start();  }  public synchronized void syncMethod1() {    for (int i = 0; i < 5; i++) {      System.out.println(Thread.currentThread().getName() + " at syncMethod1(): " + i);      try {        Thread.sleep(500);      } catch (InterruptedException ie) {      }    }  }  public synchronized void syncMethod2() {    for (int i = 0; i < 5; i++) {      System.out.println(Thread.currentThread().getName() + " at syncMethod2(): " + i);      try {        Thread.sleep(500);      } catch (InterruptedException ie) {      }    }  }}

輸出結果:

A at syncMethod1(): 0A at syncMethod1(): 1A at syncMethod1(): 2A at syncMethod1(): 3A at syncMethod1(): 4B at syncMethod2(): 0B at syncMethod2(): 1B at syncMethod2(): 2B at syncMethod2(): 3B at syncMethod2(): 4

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 沛县| 包头市| 馆陶县| 临汾市| 宝鸡市| 茂名市| 桑植县| 丹东市| 布拖县| 安阳市| 东方市| 亚东县| 兴安县| 红河县| 隆子县| 平果县| 方正县| 宁武县| 陆良县| 祥云县| 安达市| 施甸县| 吴忠市| 溧阳市| 广安市| 鹤岗市| 虎林市| 林甸县| 六安市| 罗田县| 海阳市| 筠连县| 洪雅县| 南木林县| 淮阳县| 沂水县| 阿荣旗| 宁乡县| 陈巴尔虎旗| 鄂州市| 长宁县|