疯狂

STANDING ON THE SHOULDERS OF GIANTS
posts - 481, comments - 486, trackbacks - 0, articles - 1
  BlogJava :: 首页 :: 新随笔 :: 联系 :: 聚合  :: 管理

ReadWriteLock

Posted on 2011-10-17 16:59 疯狂 阅读(992) 评论(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的操作将无法进行,一直等待。


只有注册用户登录后才能发表评论。


网站导航: