瘋狂

          STANDING ON THE SHOULDERS OF GIANTS
          posts - 481, comments - 486, trackbacks - 0, articles - 1
            BlogJava :: 首頁 :: 新隨筆 :: 聯系 :: 聚合  :: 管理

          ReadWriteLock

          Posted on 2011-10-17 16:59 瘋狂 閱讀(1128) 評論(0)  編輯  收藏 所屬分類: concurrent
               線程讀寫同一個對象的數據是很普遍的,通常,要避免讀寫沖突,必須保證任何時候僅有一個線程在寫入,有線程正在讀取的時候,寫入操作就必須等待。簡單說,就是要避免“寫-寫”沖突和“讀-寫”沖突。但是同時讀是允許的,因為“讀-讀”不沖突,而且很安全。
            沖jdk1.5開始可以使用ReadWriteLock類來防止讀寫沖突.它有一個已有的實現ReentrantReadWriteLock。
          ReentrantReadWriteLock使用內部維護的讀寫鎖來防止讀寫沖突;
           
            public ReentrantReadWriteLock.WriteLock writeLock() return writerLock; }
              
          public ReentrantReadWriteLock.ReadLock  readLock()  return readerLock; }
          示例代碼如下:

          public class RreadWriteLockTest {

            ReadWriteLock readWriteLock = new ReentrantReadWriteLock();
            public int i  = 0;
          //讀取
           public void read() throws InterruptedException{
            readWriteLock.readLock().lock();//獲取讀鎖
            System.out.println("read thread:"+Thread.currentThread().getName());
            Thread.sleep(10000);
            System.out.println("read:"+i);
            readWriteLock.readLock().unlock();
           }
          //寫入
           public void write() throws InterruptedException{
            
            readWriteLock.writeLock().lock();//獲取寫鎖
            System.out.println("write thread:"+Thread.currentThread().getName());
            Thread.sleep(10000);
            i = 2;
            System.out.println("write:"+i);
          readWriteLock.writeLock().unlock();
           }
          }
          測試代碼:
          1 測試兩個同時讀的,結果都能同時讀取。
          2 測試一個讀,一個寫的,需要其中一個釋放鎖之后才能進行另外一個操作
          public static void main(String[] args) throws InterruptedException {
            final RreadWriteLockTest lockTest= new RreadWriteLockTest();
            new Thread(new Runnable() {
             
             @Override
             public void run() {
              try {
               lockTest.write();
              } catch (InterruptedException e) {
               e.printStackTrace();
              }
             }
            }).start();
            Thread.sleep(2000);
           new Thread(new Runnable() {
              @Override
              public void run() {
               try {
                lockTest.read();
               } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
               }
              }
             }).start();
           }
          打印如下:
          write thread:Thread-0執行完之后(10秒之后)才執行read thread:Thread-1

          注意:執行完以后一定要執行unlock,要不lock的計數沒有-1,這樣對應read或者write的操作將無法進行,一直等待。


          只有注冊用戶登錄后才能發表評論。


          網站導航:
           
          主站蜘蛛池模板: 托里县| 防城港市| 永善县| 虹口区| 惠来县| 肇东市| 利津县| 台北县| 汾阳市| 仁寿县| 县级市| 漳州市| 博爱县| 阆中市| 绵阳市| 长寿区| 三门县| 榆树市| 大兴区| 焉耆| 曲麻莱县| 伽师县| 白水县| 汉川市| 通许县| 张北县| 鄂托克旗| 长岭县| 云林县| 新沂市| 百色市| 天镇县| 孟州市| 工布江达县| 辽宁省| 无棣县| 福贡县| 泸水县| 镇远县| 温宿县| 满城县|