快捷導(dǎo)航

Java 同步鎖(synchronized)詳解及實(shí)例

更新時(shí)間：2017年03月28日 17:10:50 投稿：lqh

這篇文章主要介紹了Java 同步鎖(synchronized)詳解及實(shí)例的相關(guān)資料,需要的朋友可以參考下

Java 同步鎖(synchronized)詳解及實(shí)例

Java中cpu分給每個(gè)線程的時(shí)間片是隨機(jī)的并且在Java中好多都是多個(gè)線程共用一個(gè)資源，比如火車賣票，火車票是一定的，但賣火車票的窗口到處都有，每個(gè)窗口就相當(dāng)于一個(gè)線程，這么多的線程共用所有的火車票這個(gè)資源。如果在一個(gè)時(shí)間點(diǎn)上，兩個(gè)線程同時(shí)使用這個(gè)資源，那他們?nèi)〕龅幕疖嚻笔且粯拥模ㄗ惶?hào)一樣），這樣就會(huì)給乘客造成麻煩。比如下面程序：

package com.pakage.ThreadAndRunnable; 
 
public class Runnable_demo implements Runnable{ 
  private int ticket=10; 
  public Runnable_demo(){    
  } 
  @Override 
  public void run() { 
    for(int i=0;i<20;i++){ 
        if(this.ticket>0){ 
          //休眠1s秒中，為了使效果更明顯，否則可能出不了效果 
          try { 
            Thread.sleep(1000); 
          } catch (Exception e) { 
            e.printStackTrace(); 
          } 
          System.out.println(Thread.currentThread().getName()+"號(hào)窗口賣出："+this.ticket--+"號(hào)票"); 
        } 
       
    } 
  } 
   
   public static void main(String args[]){ 
     Runnable_demo demo=new Runnable_demo(); 
     //基于火車票創(chuàng)建三個(gè)窗口 
     new Thread(demo,"a").start(); 
     new Thread(demo,"b").start(); 
     new Thread(demo,"c").start(); 
   } 
   
}

程序運(yùn)行結(jié)果:

我們可以看到c號(hào)窗口和和b號(hào)窗口都賣出了10號(hào)票，并且a號(hào)和b號(hào)窗口分別賣出了0號(hào)和-1號(hào)票。造成這種情況的原因是1、c線程和b線程在ticket=10的時(shí)候，c線程取出10號(hào)票以后，ticket還沒(méi)來(lái)的及減1,b線程就取出了ticket此時(shí)ticket還等于10；2、在ticket=1時(shí)，c線程取出了1號(hào)票，ticket還沒(méi)來(lái)的及減1，a、b線程就先后進(jìn)入了if判斷語(yǔ)句，這時(shí)ticket減1了，那么當(dāng)a、b線程取票的時(shí)候就取到了0號(hào)和-1號(hào)票。

出現(xiàn)了上述情況怎樣改變呢，我們可以這樣做：當(dāng)一個(gè)線程要使用火車票這個(gè)資源時(shí)，我們就交給它一把鎖，等它把事情做完后在把鎖給另一個(gè)要用這個(gè)資源的線程。這樣就不會(huì)出現(xiàn)上述情況。實(shí)現(xiàn)這個(gè)鎖的功能就需要用到synchronized這個(gè)關(guān)鍵字。

synchronized這個(gè)關(guān)鍵字有兩種用法1、放方法名前形成同步方法；2、放在塊前構(gòu)成同步塊。

1、使用同步方法將上面的例子該為：

package com.pakage.ThreadAndRunnable; 
 
public class Runnable_demo implements Runnable{ 
  private int ticket=10; 
  public Runnable_demo(){    
  } 
  @Override 
  public void run() { 
    for(int i=0;i<20;i++){ 
        if(this.ticket>0){ 
          //休眠1s秒中，為了使效果更明顯，否則可能出不了效果 
          try { 
            Thread.sleep(1000); 
          } catch (Exception e) { 
            e.printStackTrace(); 
          } 
          this.sale(); 
        } 
       
    } 
  } 
   
  public synchronized void sale(){ 
    if(this.ticket>0){ 
      System.out.println(Thread.currentThread().getName()+"號(hào)窗口賣出："+this.ticket--+"號(hào)票"); 
    } 
  } 
   
   public static void main(String args[]){ 
     Runnable_demo demo=new Runnable_demo(); 
     //基于火車票創(chuàng)建三個(gè)窗口 
     new Thread(demo,"a").start(); 
     new Thread(demo,"b").start(); 
     new Thread(demo,"c").start(); 
   } 
   
}

程序的輸出結(jié)果為：

2、使用同步塊修改上面的例子：

package com.pakage.ThreadAndRunnable; 
 
public class Runnable_demo implements Runnable{ 
  private int ticket=10; 
  public Runnable_demo(){    
  } 
  @Override 
  public void run() { 
    for(int i=0;i<20;i++){ 
      <span style="color:#ff0000">synchronized</span>(this){ 
        if(this.ticket>0){ 
          //休眠1s秒中，為了使效果更明顯，否則可能出不了效果 
          try { 
            Thread.sleep(1000); 
          } catch (Exception e) { 
            e.printStackTrace(); 
          } 
          System.out.println(Thread.currentThread().getName()+"號(hào)窗口賣出："+this.ticket--+"號(hào)票"); 
        } 
      } 
       
    } 
  } 
   
   public static void main(String args[]){ 
     Runnable_demo demo=new Runnable_demo(); 
     //基于火車票創(chuàng)建三個(gè)窗口 
     new Thread(demo,"a").start(); 
     new Thread(demo,"b").start(); 
     new Thread(demo,"c").start(); 
   } 
   
}

程序的輸出結(jié)果：