qileilove

          blog已經轉移至github,大家請訪問 http://qaseven.github.io/

          同步塊

          打個比方:一個object就像一個大房子,大門永遠打開。房子里有很多房間(也就是方法)。這些房間有上鎖的(synchronized方法),和不上鎖之分(普通方法)。房門口放著一把鑰匙(key),這把鑰匙可以打開所有上鎖的房間。另外我把所有想調用該對象方法的線程比喻成想進入這房子某個房間的人。所有的東西就這么多了,下面我們看看這些東西之間如何作用的。

          在此我們先來明確一下我們的前提條件。該對象至少有一個synchronized方法,否則這個key還有啥意義。當然也就不會有我們的這個主題了。

          一個人想進入某間上了鎖的房間,他來到房子門口,看見鑰匙在那兒(說明暫時還沒有其他人要使用上鎖的房間)。于是他走上去拿到了鑰匙,并且按照自己的計劃使用那些房間。注意一點,他每次使用完一次上鎖的房間后會馬上把鑰匙還回去。即使他要連續使用兩間上鎖的房間,中間他也要把鑰匙還回去,再取回來。

          因此,普通情況下鑰匙的使用原則是:“隨用隨借,用完即還。”

          這時其他人可以不受限制的使用那些不上鎖的房間,一個人用一間可以,兩個人用一間也可以,沒限制。但是如果當某個人想要進入上鎖的房間,他就要跑到大門口去看看了。有鑰匙當然拿了就走,沒有的話,就只能等了。

          要是很多人在等這把鑰匙,等鑰匙還回來以后,誰會優先得到鑰匙?Not guaranteed。象前面例子里那個想連續使用兩個上鎖房間的家伙,他中間還鑰匙的時候如果還有其他人在等鑰匙,那么沒有任何保證這家伙能再次拿到。(JAVA規范在很多地方都明確說明不保證,象Thread.sleep()休息后多久會返回運行,相同優先權的線程那個首先被執行,當要訪問對象的鎖被釋放后處于等待池的多個線程哪個會優先得到,等等。我想最終的決定權是在JVM,之所以不保證,就是因為JVM在做出上述決定的時候,絕不是簡簡單單根據一個條件來做出判斷,而是根據很多條。而由于判斷條件太多,如果說出來可能會影響JAVA的推廣,也可能是因為知識產權保護的原因吧。SUN給了個不保證就混過去了。無可厚非。但我相信這些不確定,并非完全不確定。因為計算機這東西本身就是按指令運行的。即使看起來很隨機的現象,其實都是有規律可尋。學過計算機的都知道,計算機里隨機數的學名是偽隨機數,是人運用一定的方法寫出來的,看上去隨機罷了。另外,或許是因為要想弄的確定太費事,也沒多大意義,所以不確定就不確定了吧。)

          再來看看同步代碼塊。和同步方法有小小的不同。

          1.從尺寸上講,同步代碼塊比同步方法小。你可以把同步代碼塊看成是沒上鎖房間里的一塊用帶鎖的屏風隔開的空間。

          2.同步代碼塊還可以人為的指定獲得某個其它對象的key。就像是指定用哪一把鑰匙才能開這個屏風的鎖,你可以用本房的鑰匙;你也可以指定用另一個房子的鑰匙才能開,這樣的話,你要跑到另一棟房子那兒把那個鑰匙拿來,并用那個房子的鑰匙來打開這個房子的帶鎖的屏風。

          記住你獲得的那另一棟房子的鑰匙,并不影響其他人進入那棟房子沒有鎖的房間。

          為什么要使用同步代碼塊呢?我想應該是這樣的:首先對程序來講同步的部分很影響運行效率,而一個方法通常是先創建一些局部變量,再對這些變量做一些操作,如運算,顯示等等;而同步所覆蓋的代碼越多,對效率的影響就越嚴重。因此我們通常盡量縮小其影響范圍。如何做?同步代碼塊。我們只把一個方法中該同步的地方同步,比如運算。

          另外,同步代碼塊可以指定鑰匙這一特點有個額外的好處,是可以在一定時期內霸占某個對象的key。還記得前面說過普通情況下鑰匙的使用原則嗎。現在不是普通情況了。你所取得的那把鑰匙不是永遠不還,而是在退出同步代碼塊時才還。

          還用前面那個想連續用兩個上鎖房間的家伙打比方。怎樣才能在用完一間以后,繼續使用另一間呢。用同步代碼塊吧。先創建另外一個線程,做一個同步代碼塊,把那個代碼塊的鎖指向這個房子的鑰匙。然后啟動那個線程。只要你能在進入那個代碼塊時抓到這房子的鑰匙,你就可以一直保留到退出那個代碼塊。也就是說你甚至可以對本房內所有上鎖的房間遍歷,甚至再sleep(10*60*1000),而房門口卻還有1000個線程在等這把鑰匙呢。很過癮吧。

          在此對sleep()方法和鑰匙的關聯性講一下。一個線程在拿到key后,且沒有完成同步的內容時,如果被強制sleep()了,那key還一直在它那兒。直到它再次運行,做完所有同步內容,才會歸還key。記住,那家伙只是干活干累了,去休息一下,他并沒干完他要干的事。為了避免別人進入那個房間把里面搞的一團糟,即使在睡覺的時候他也要把那唯一的鑰匙戴在身上。

          最后,也許有人會問,為什么要一把鑰匙通開,而不是一個鑰匙一個門呢?我想這純粹是因為復雜性問題。一個鑰匙一個門當然更安全,但是會牽扯好多問題。鑰匙的產生,保管,獲得,歸還等等。其復雜性有可能隨同步方法的增加呈幾何級數增加,嚴重影響效率。

          這也算是一個權衡的問題吧。為了增加一點點安全性,導致效率大大降低,是多么不可取啊。

          摘自:http://www.54bk.com/more.asp?name=czp&id=2097

          一、當兩個并發線程訪問同一個對象object中的這個synchronized(this)同步代碼塊時,一個時間內只能有一個線程得到執行。另一個線程必須等待當前線程執行完這個代碼塊以后才能執行該代碼塊。

          二、然而,當一個線程訪問object的一個synchronized(this)同步代碼塊時,另一個線程仍然可以訪問該object中的非synchronized(this)同步代碼塊。

          三、尤其關鍵的是,當一個線程訪問object的一個synchronized(this)同步代碼塊時,其他線程對object中所有其它synchronized(this)同步代碼塊的訪問將被阻塞。

          四、第三個例子同樣適用其它同步代碼塊。也就是說,當一個線程訪問object的一個synchronized(this)同步代碼塊時,它就獲得了這個object的對象鎖。結果,其它線程對該object對象所有同步代碼部分的訪問都被暫時阻塞。

          五、以上規則對其它對象鎖同樣適用.

          舉例說明:

          一、當兩個并發線程訪問同一個對象object中的這個synchronized(this)同步代碼塊時,一個時間內只能有一個線程得到執行。另一個線程必須等待當前線程執行完這個代碼塊以后才能執行該代碼塊。

          package ths;

          public class Thread1 implements Runnable {
          public void run() {
          synchronized(this) {
          for (int i = 0; i < 5; i++) {
          System.out.println(Thread.currentThread().getName() + " synchronized loop " + i);
          }
          }
          }
          public static void main(String[] args) {
          Thread1 t1 = new Thread1();
          Thread ta = new Thread(t1, "A");
          Thread tb = new Thread(t1, "B");
          ta.start();
          tb.start();
          }
          }

          結果:

          A synchronized loop 0
          A synchronized loop 1
          A synchronized loop 2
          A synchronized loop 3
          A synchronized loop 4
          B synchronized loop 0
          B synchronized loop 1
          B synchronized loop 2
          B synchronized loop 3
          B synchronized loop 4

          二、然而,當一個線程訪問object的一個synchronized(this)同步代碼塊時,另一個線程仍然可以訪問該object中的非synchronized(this)同步代碼塊。

          package ths;

          public class Thread2 {
          public void m4t1() {
          synchronized(this) {
          int i = 5;
          while( i-- > 0) {
          System.out.println(Thread.currentThread().getName() + " : " + i);
          try {
          Thread.sleep(500);
          } catch (InterruptedException ie) {
          }
          }
          }
          }
          public void m4t2() {
          int i = 5;
          while( i-- > 0) {
          System.out.println(Thread.currentThread().getName() + " : " + i);
          try {
          Thread.sleep(500);
          } catch (InterruptedException ie) {
          }
          }
          }
          public static void main(String[] args) {
          final Thread2 myt2 = new Thread2();
          Thread t1 = new Thread(
          new Runnable() {
          public void run() {
          myt2.m4t1();
          }
          }, "t1"
          );
          Thread t2 = new Thread(
          new Runnable() {
          public void run() {
          myt2.m4t2();
          }
          }, "t2"
          );
          t1.start();
          t2.start();
          }
          }

          結果:

          t1 : 4
          t2 : 4
          t1 : 3
          t2 : 3
          t1 : 2
          t2 : 2
          t1 : 1
          t2 : 1
          t1 : 0
          t2 : 0

          三、尤其關鍵的是,當一個線程訪問object的一個synchronized(this)同步代碼塊時,其他線程對object中所有其它synchronized(this)同步代碼塊的訪問將被阻塞。

          //修改Thread2.m4t2()方法:

          public void m4t2() {
          synchronized(this) {
          int i = 5;
          while( i-- > 0) {
          System.out.println(Thread.currentThread().getName() + " : " + i);
          try {
          Thread.sleep(500);
          } catch (InterruptedException ie) {
          }
          }
          }

          }

          結果:

          t1 : 4
          t1 : 3
          t1 : 2
          t1 : 1
          t1 : 0
          t2 : 4
          t2 : 3
          t2 : 2
          t2 : 1
          t2 : 0

          四、第三個例子同樣適用其它同步代碼塊。也就是說,當一個線程訪問object的一個synchronized(this)同步代碼塊時,它就獲得了這個object的對象鎖。結果,其它線程對該object對象所有同步代碼部分的訪問都被暫時阻塞。

          //修改Thread2.m4t2()方法如下:

          public synchronized void m4t2() {
          int i = 5;
          while( i-- > 0) {
          System.out.println(Thread.currentThread().getName() + " : " + i);
          try {
          Thread.sleep(500);
          } catch (InterruptedException ie) {
          }
          }
          }

          結果:

          t1 : 4
          t1 : 3
          t1 : 2
          t1 : 1
          t1 : 0
          t2 : 4
          t2 : 3
          t2 : 2
          t2 : 1
          t2 : 0

          五、以上規則對其它對象鎖同樣適用:

          package ths;

          public class Thread3 {
          class Inner {
          private void m4t1() {
          int i = 5;
          while(i-- > 0) {
          System.out.println(Thread.currentThread().getName() + " : Inner.m4t1()=" + i);
          try {
          Thread.sleep(500);
          } catch(InterruptedException ie) {
          }
          }
          }
          private void m4t2() {
          int i = 5;
          while(i-- > 0) {
          System.out.println(Thread.currentThread().getName() + " : Inner.m4t2()=" + i);
          try {
          Thread.sleep(500);
          } catch(InterruptedException ie) {
          }
          }
          }
          }
          private void m4t1(Inner inner) {
          synchronized(inner) { //使用對象鎖
          inner.m4t1();
          }
          }
          private void m4t2(Inner inner) {
          inner.m4t2();
          }
          public static void main(String[] args) {
          final Thread3 myt3 = new Thread3();
          final Inner inner = myt3.new Inner();
          Thread t1 = new Thread(
          new Runnable() {
          public void run() {
          myt3.m4t1(inner);
          }
          }, "t1"
          );
          Thread t2 = new Thread(
          new Runnable() {
          public void run() {
          myt3.m4t2(inner);
          }
          }, "t2"
          );
          t1.start();
          t2.start();
          }
          }

          結果:

          盡管線程t1獲得了對Inner的對象鎖,但由于線程t2訪問的是同一個Inner中的非同步部分。所以兩個線程互不干擾。

          t1 : Inner.m4t1()=4
          t2 : Inner.m4t2()=4
          t1 : Inner.m4t1()=3
          t2 : Inner.m4t2()=3
          t1 : Inner.m4t1()=2
          t2 : Inner.m4t2()=2
          t1 : Inner.m4t1()=1
          t2 : Inner.m4t2()=1
          t1 : Inner.m4t1()=0
          t2 : Inner.m4t2()=0

          現在在Inner.m4t2()前面加上synchronized:

          private synchronized void m4t2() {
          int i = 5;
          while(i-- > 0) {
          System.out.println(Thread.currentThread().getName() + " : Inner.m4t2()=" + i);
          try {
          Thread.sleep(500);
          } catch(InterruptedException ie) {
          }
          }
          }

          結果:

          盡管線程t1與t2訪問了同一個Inner對象中兩個毫不相關的部分,但因為t1先獲得了對Inner的對象鎖,所以t2對Inner.m4t2()的訪問也被阻塞,因為m4t2()是Inner中的一個同步方法。

          t1 : Inner.m4t1()=4
          t1 : Inner.m4t1()=3
          t1 : Inner.m4t1()=2
          t1 : Inner.m4t1()=1
          t1 : Inner.m4t1()=0
          t2 : Inner.m4t2()=4
          t2 : Inner.m4t2()=3
          t2 : Inner.m4t2()=2
          t2 : Inner.m4t2()=1
          t2 : Inner.m4t2()=0

          同步買票問題

          public class TicketsSystem {
           public static void main(String[] args) {
            SellThread st = new SellThread();
            Thread th1 = new Thread(st);
            th1.start();

            Thread th2 = new Thread(st);
            th2.start();

            Thread th3 = new Thread(st);
            th3.start();
           }

          }

          class SellThread implements Runnable {
           private int number=10;
           String s = new String();

           public void run() {
            while (number > 0) {
             synchronized (s) {
              System.out.println("第" + number + "個人在"
                + Thread.currentThread().getName() + "買票");
             }
             number--;
             try {
              Thread.sleep(10);
             } catch (InterruptedException e) {
              e.printStackTrace();
             }
            }
           }
          }

           

          Java線程:線程的同步-同步塊
           
          對于同步,除了同步方法外,還可以使用同步代碼塊,有時候同步代碼塊會帶來比同步方法更好的效果。
           
          追其同步的根本的目的,是控制競爭資源的正確的訪問,因此只要在訪問競爭資源的時候保證同一時刻只能一個線程訪問即可,因此Java引入了同步代碼快的策略,以提高性能。
           
          在上個例子的基礎上,對oper方法做了改動,由同步方法改為同步代碼塊模式,程序的執行邏輯并沒有問題。
           
           
          /**
          * Java線程:線程的同步-同步代碼塊
          *
          * @author leizhimin 2009-11-4 11:23:32
          */

          public class Test {
                  public static void main(String[] args) {
                          User u = new User("張三", 100);
                          MyThread t1 = new MyThread("線程A", u, 20);
                          MyThread t2 = new MyThread("線程B", u, -60);
                          MyThread t3 = new MyThread("線程C", u, -80);
                          MyThread t4 = new MyThread("線程D", u, -30);
                          MyThread t5 = new MyThread("線程E", u, 32);
                          MyThread t6 = new MyThread("線程F", u, 21);

                          t1.start();
                          t2.start();
                          t3.start();
                          t4.start();
                          t5.start();
                          t6.start();
                  }
          }

          class MyThread extends Thread {
                  private User u;
                  private int y = 0;

                  MyThread(String name, User u, int y) {
                          super(name);
                          this.u = u;
                          this.y = y;
                  }

                  public void run() {
                          u.oper(y);
                  }
          }

          class User {
                  private String code;
                  private int cash;

                  User(String code, int cash) {
                          this.code = code;
                          this.cash = cash;
                  }

                  public String getCode() {
                          return code;
                  }

                  public void setCode(String code) {
                          this.code = code;
                  }

                  /**
                   * 業務方法
                   *
                   * @param x 添加x萬元
                   */

                  public void oper(int x) {
                          try {
                                  Thread.sleep(10L);
                                  synchronized (this) {
                                          this.cash += x;
                                          System.out.println(Thread.currentThread().getName() + "運行結束,增加“" + x + "”,當前用戶賬戶余額為:" + cash);
                                  }
                                  Thread.sleep(10L);
                          } catch (InterruptedException e) {
                                  e.printStackTrace();
                          }
                  }

                  @Override
                  public String toString() {
                          return "User{" +
                                          "code='" + code + '\'' +
                                          ", cash=" + cash +
                                          '}';
                  }
          }
           
          線程E運行結束,增加“32”,當前用戶賬戶余額為:132
          線程B運行結束,增加“-60”,當前用戶賬戶余額為:72
          線程D運行結束,增加“-30”,當前用戶賬戶余額為:42
          線程F運行結束,增加“21”,當前用戶賬戶余額為:63
          線程C運行結束,增加“-80”,當前用戶賬戶余額為:-17
          線程A運行結束,增加“20”,當前用戶賬戶余額為:3

          Process finished with exit code 0
           
          注意:
          在使用synchronized關鍵字時候,應該盡可能避免在synchronized方法或synchronized塊中使用sleep或者yield方法,因為synchronized程序塊占有著對象鎖,你休息那么其他的線程只能一邊等著你醒來執行完了才能執行。不但嚴重影響效率,也不合邏輯。
          同樣,在同步程序塊內調用yeild方法讓出CPU資源也沒有意義,因為你占用著鎖,其他互斥線程還是無法訪問同步程序塊。當然與同步程序塊無關的線程可以獲得更多的執行時間。

           

          posted on 2011-09-23 10:36 順其自然EVO 閱讀(547) 評論(0)  編輯  收藏

          <2011年9月>
          28293031123
          45678910
          11121314151617
          18192021222324
          2526272829301
          2345678

          導航

          統計

          常用鏈接

          留言簿(55)

          隨筆分類

          隨筆檔案

          文章分類

          文章檔案

          搜索

          最新評論

          閱讀排行榜

          評論排行榜

          主站蜘蛛池模板: 合水县| 精河县| 镇江市| 盐池县| 新晃| 兰西县| 乌鲁木齐县| 库尔勒市| 屏东县| 宣城市| 扶沟县| 廉江市| 新竹县| 鄂尔多斯市| 阿合奇县| 靖州| 芦山县| 河池市| 沽源县| 类乌齐县| 西吉县| 秭归县| 密山市| 香格里拉县| 嘉义县| 陆河县| 东港市| 高雄县| 禹州市| 崇礼县| 定远县| 裕民县| 繁峙县| 修武县| 萨嘎县| 昭苏县| 乐亭县| 伊春市| 灌云县| 永康市| 正镶白旗|