码迷,mamicode.com
首页 > 其他好文 > 详细

ReadWriteLock ReentrantReadWriteLock

时间:2018-03-01 17:29:06      阅读:149      评论:0      收藏:0      [点我收藏+]

标签:body   lte   main   next   star   rup   更新   并发包   tin   

ReadWriteLock管理一组锁,一个是只读的锁,一个是写锁。读锁可以在没有写锁的时候被多个线程同时持有,写锁是独占的。 


所有读写锁的实现必须确保写操作对读操作的内存影响。换句话说,一个获得了读锁的线程必须能看到前一个释放的写锁所更新的内容。

 
读写锁比互斥锁允许对于共享数据更大程度的并发。每次只能有一个写线程,但是同时可以有多个线程并发地读数据。ReadWriteLock适用于读多写少的并发情况。 


Java并发包中ReadWriteLock是一个接口,主要有两个方法,如下:

 

public interface ReadWriteLock {
    /**
     * 返回读锁
     */
    Lock readLock();

    /**
     * 返回写锁
     */
    Lock writeLock();
}

Java并发库中ReetrantReadWriteLock实现了ReadWriteLock接口并添加了可重入的特性。

实例的代码

 

package cn.itcast.heima2;

import java.util.Random;
import java.util.concurrent.locks.ReadWriteLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;

public class ReadWriteLockTest {
    public static void main(String[] args) {
        final Queue3 q3 = new Queue3();
        for (int i = 0; i < 3; i++) {

            new Thread() {
                public void run() {
                    while (true) {
                        q3.get();
                    }
                }

            }.start();

            new Thread() {
                public void run() {
                    while (true) {
                        q3.put(new Random().nextInt(10000));
                    }
                }
            }.start();
        }

    }
}

class Queue3 {
    private Object data = null;//共享数据,只能有一个线程能写该数据,但可以有多个线程同时读该数据。
    ReadWriteLock rwl = new ReentrantReadWriteLock(true);  //true为公平锁,false则为打乱

    public void get() {
        rwl.readLock().lock();  //读锁上锁
        try {
            System.out.println(Thread.currentThread().getName() + " be ready to read data!");
            Thread.sleep((long) (Math.random() * 1000));
            System.out.println(Thread.currentThread().getName() + " have read data :" + data);
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            rwl.readLock().unlock();  //读锁解锁
        }
    }

    public void put(Object data) {

        rwl.writeLock().lock();  //写锁上锁
        try {
            System.out.println(Thread.currentThread().getName() + " be ready to write data!");
            Thread.sleep((long) (Math.random() * 1000));
            this.data = data;
            System.out.println(Thread.currentThread().getName() + " have write data: " + data);
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            rwl.writeLock().unlock(); //写锁解锁
        }


    }
}

结果:

Thread-0 be ready to read data!
Thread-2 be ready to read data!
Thread-4 be ready to read data!
Thread-4 have read data :null
Thread-2 have read data :null
Thread-0 have read data :null
Thread-3 be ready to write data!
Thread-3 have write data: 8786
Thread-5 be ready to write data!
Thread-5 have write data: 4237
Thread-1 be ready to write data!
Thread-1 have write data: 2771
Thread-4 be ready to read data!
Thread-2 be ready to read data!
Thread-0 be ready to read data!
Thread-2 have read data :2771
Thread-0 have read data :2771
Thread-4 have read data :2771
Thread-3 be ready to write data!
Thread-3 have write data: 4449
Thread-5 be ready to write data!

 

ReadWriteLock ReentrantReadWriteLock

标签:body   lte   main   next   star   rup   更新   并发包   tin   

原文地址:https://www.cnblogs.com/tinya/p/8488524.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!