快捷導(dǎo)航

Java多線程編程中線程鎖與讀寫(xiě)鎖的使用示例

更新時(shí)間：2016年04月24日 08:53:07 投稿：goldensun

這篇文章主要介紹了Java多線程編程中線程鎖與讀寫(xiě)鎖的使用示例,鎖是控制程序多線程并發(fā)的重要手段,需要的朋友可以參考下

線程鎖Lock
Lock 相當(dāng)于當(dāng)前對(duì)象的 Synchronized

import java.util.concurrent.locks.Lock; 
import java.util.concurrent.locks.ReentrantLock; 
/* 
 * Lock lock = new ReentrantLock(); 
 * lock.lock();  lock.unLock(); 
 * 類(lèi)似于 synchronized，但不能與synchronized 混用 
 */ 
public class LockTest { 
  public static void main(String[] args) { 
    final Outer outer = new LockTest().new Outer(); 
    new Thread(new Runnable() { 
 
      @Override 
      public void run() { 
        // TODO Auto-generated method stub 
        while (true) { 
          outer.out1("zhangxiaoxiao"); 
          outer.out2("lihuoming"); 
        } 
      } 
 
    }).start(); 
    new Thread(new Runnable() { 
 
      @Override 
      public void run() { 
        // TODO Auto-generated method stub 
        while (true) { 
          outer.out1("zhangxiaoxiao"); 
          outer.out2("lihuoming"); 
        } 
      } 
 
    }).start(); 
 
  } 
  class Outer { 
    Lock lock = new ReentrantLock(); 
    void out1(String name) { 
      lock.lock(); 
      int len = name.length(); 
      for (int i = 0; i < len; i++) { 
        System.out.print(name.charAt(i)); 
      } 
      System.out.println(); 
      lock.unlock(); 
    } 
    void out2(String name) { 
      lock.lock(); 
      int len = name.length(); 
      for (int i = 0; i < len; i++) { 
        System.out.print(name.charAt(i)); 
      } 
      System.out.println(); 
      lock.unlock(); 
    } 
  } 
}

讀寫(xiě)鎖 ReentrantReadWriteLock

讀寫(xiě)鎖：允許多條線程同時(shí)讀；不能讀中有寫(xiě)；不能寫(xiě)中有讀；不能寫(xiě)中有寫(xiě)

import java.util.HashMap; 
import java.util.Map; 
import java.util.concurrent.locks.ReadWriteLock; 
import java.util.concurrent.locks.ReentrantReadWriteLock; 
/* 
 * 問(wèn)題：設(shè)計(jì)一個(gè) 緩存機(jī)制 的 偽代碼 
 *  從集合中讀取數(shù)據(jù)，讀取不到，就寫(xiě)入，再考慮多線程并發(fā)的情況  
 */ 
public class ReadWriteLockTest2 { 
  private Map<String, Object> data = new HashMap<String, Object>(); 
  private ReadWriteLock lock = new ReentrantReadWriteLock();  
  //讀寫(xiě)鎖 
  public Object getInstance1(String key, Object obj) { 
    lock.readLock().lock(); 
    Object value = null; 
    try { 
      value = data.get(key); 
      if (value == null) {//一條線程進(jìn)入這里， 
        lock.readLock().unlock();//讀鎖解了，其他線程就可能也到這了 
        lock.writeLock().lock();//只能有一條線程到這，寫(xiě)鎖開(kāi)啟，要寫(xiě)入數(shù)據(jù)了 
        if (data.get(key) == null) { 
          value = obj;   
            /*先判斷數(shù)據(jù)，如果不存在，才寫(xiě)入，，因?yàn)?界時(shí)當(dāng)寫(xiě)鎖解除后，其他 
              線程，再想寫(xiě)入時(shí)， 判斷到數(shù)據(jù)存在 ，就跳過(guò)了。就不會(huì)發(fā)生同時(shí)寫(xiě)入的情況 
            */    
          data.put(key, value);  
        } 
        lock.writeLock().unlock();//寫(xiě)完了，解鎖 
        lock.readLock().lock(); 
      } 
    } finally { 
      lock.readLock().unlock(); 
    }   
    return value; 
  }

您可能感興趣的文章: