隨筆 - 11  文章 - 2  trackbacks - 0
          <2025年6月>
          25262728293031
          1234567
          891011121314
          15161718192021
          22232425262728
          293012345

          常用鏈接

          留言簿

          隨筆分類

          隨筆檔案

          文章分類

          文章檔案

          新聞分類

          link

          搜索

          •  

          最新評論

          閱讀排行榜

          評論排行榜

          轉至:http://blog.csdn.net/phinecos/archive/2010/03/13/5377915.aspx

          多線程的同步依靠的是對象鎖機制,synchronized關鍵字的背后就是利用了封鎖來實現(xiàn)對共享資源的互斥訪問。

          下面以一個簡單的實例來進行對比分析。實例要完成的工作非常簡單,就是創(chuàng)建10個線程,每個線程都打印從099100個數(shù)字,我們希望線程之間不會出現(xiàn)交叉亂序打印,而是順序地打印。

          先來看第一段代碼,這里我們在run()方法中加入了synchronized關鍵字,希望能對run方法進行互斥訪問,但結果并不如我們希望那樣,這是因為這里synchronized鎖住的是this對象,即當前運行線程對象本身。代碼中創(chuàng)建了10個線程,而每個線程都持有this對象的對象鎖,這不能實現(xiàn)線程的同步。

          代碼
          package com.vista;

          class MyThread implements java.lang.Runnable
          {
              
          private int threadId;

              
          public MyThread(int id)
              {
                  
          this.threadId = id;
              }
              @Override
              
          public synchronized void run() 
              {
                  
          for (int i = 0; i < 100++i)
                  {
                      System.out.println(
          "Thread ID: " + this.threadId + " : " + i);
                  }
              }
          }
          public class ThreadDemo
          {
              
          /**
               * 
          @param args
               * 
          @throws InterruptedException 
               
          */
              
          public static void main(String[] args) throws InterruptedException
              {
                  
          for (int i = 0; i < 10++i)
                  {
                      
          new Thread(new MyThread(i)).start();
                      Thread.sleep(
          1);
                  }
              }
          }

                從上述代碼段可以得知,要想實現(xiàn)線程的同步,則這些線程必須去競爭一個唯一的共享的對象鎖。

                基于這種思想,我們將第一段代碼修改如下所示,在創(chuàng)建啟動線程之前,先創(chuàng)建一個線程之間競爭使用的Object對象,然后將這個Object對象的引用傳遞給每一個線程對象的lock成員變量。這樣一來,每個線程的lock成員都指向同一個Object對象。我們在run方法中,對lock對象使用synchronzied塊進行局部封鎖,這樣就可以讓線程去競爭這個唯一的共享的對象鎖,從而實現(xiàn)同步。

          代碼
          package com.vista;

          class MyThread implements java.lang.Runnable
          {
              
          private int threadId;
              
          private Object lock;
              
          public MyThread(int id, Object obj)
              {
                  
          this.threadId = id;
                  
          this.lock = obj;
              }
              @Override
              
          public  void run() 
              {
                  
          synchronized(lock)
                  {
                      
          for (int i = 0; i < 100++i)
                      {
                          System.out.println(
          "Thread ID: " + this.threadId + " : " + i);
                      }
                  }
              }
          }
          public class ThreadDemo
          {
              
          /**
               * 
          @param args
               * 
          @throws InterruptedException 
               
          */
              
          public static void main(String[] args) throws InterruptedException
              {
                  Object obj 
          = new Object();
                  
          for (int i = 0; i < 10++i)
                  {
                      
          new Thread(new MyThread(i, obj)).start();
                      Thread.sleep(
          1);
                  }
              }
          }

          從第二段代碼可知,同步的關鍵是多個線程對象競爭同一個共享資源即可,上面的代碼中是通過外部創(chuàng)建共享資源,然后傳遞到線程中來實現(xiàn)。我們也可以利用類成員變量被所有類的實例所共享這一特性,因此可以將lock用靜態(tài)成員對象來實現(xiàn),代碼如下所示:

          代碼
          package com.vista;

          class MyThread implements java.lang.Runnable
          {
              
          private int threadId;
              
          private static Object lock = new Object();
              
          public MyThread(int id)
              {
                  
          this.threadId = id;
              }
              @Override
              
          public  void run() 
              {
                  
          synchronized(lock)
                  {
                      
          for (int i = 0; i < 100++i)
                      {
                          System.out.println(
          "Thread ID: " + this.threadId + " : " + i);
                      }
                  }
              }
          }
          public class ThreadDemo 
          {
              
          /**
               * 
          @param args
               * 
          @throws InterruptedException 
               
          */
              
          public static void main(String[] args) throws InterruptedException
              {
                  
          for (int i = 0; i < 10++i)
                  {
                      
          new Thread(new MyThread(i)).start();
                      Thread.sleep(
          1);
                  }
              }
          }

          再來看第一段代碼,實例方法中加入sychronized關鍵字封鎖的是this對象本身,而在靜態(tài)方法中加入sychronized關鍵字封鎖的就是類本身。靜態(tài)方法是所有類實例對象所共享的,因此線程對象在訪問此靜態(tài)方法時是互斥訪問的,從而可以實現(xiàn)線程的同步,代碼如下所示:

          代碼
          package com.vista;

          class MyThread implements java.lang.Runnable
          {
              
          private int threadId;
              
              
          public MyThread(int id)
              {
                  
          this.threadId = id;
              }
              @Override
              
          public  void run() 
              {
                  taskHandler(
          this.threadId);
              }
              
          private static synchronized void taskHandler(int threadId)
              {
                  
          for (int i = 0; i < 100++i)
                  {
                      System.out.println(
          "Thread ID: " + threadId + " : " + i);
                  }
              }
          }
          public class ThreadDemo
          {
              
          /**
               * 
          @param args
               * 
          @throws InterruptedException 
               
          */
              
          public static void main(String[] args) throws InterruptedException
              {
                  
          for (int i = 0; i < 10++i)
                  {
                      
          new Thread(new MyThread(i)).start();
                      Thread.sleep(
          1);
                  }
              }
          }
          posted on 2010-03-22 20:05 poower 閱讀(151) 評論(0)  編輯  收藏 所屬分類: j2ee學習筆記
          主站蜘蛛池模板: 遂溪县| 惠水县| 襄汾县| 阳西县| 绵阳市| 宁安市| 凉城县| 天祝| 辰溪县| 南陵县| 沾益县| 朝阳区| 樟树市| 醴陵市| 常宁市| 桃江县| 临西县| 应用必备| 翁牛特旗| 龙口市| 丰镇市| 永靖县| 瑞丽市| 资溪县| 高邑县| 隆昌县| 浦江县| 格尔木市| 龙江县| 苍溪县| 汉沽区| 达尔| 商水县| 长子县| 二手房| 长乐市| 鹰潭市| 吉安县| 商水县| 苏州市| 五原县|