发布时间:2022-02-24 文章分类:Java知识 投稿人:优优 字号: 默认 | | 超大 打印

626

1、公平选择性,支持非公平和公平锁获取,吞吐量不公平优于公平。

2、重进入,读锁和写锁都支持线程重进入。

3、锁降级,遵循获取写锁、获取读锁、释放写锁的顺序,写锁可以降级为读锁。

实例

publicclassReadWriteLockTest{
publicstaticvoidmain(String[]args){

finalQueueq=newQueue();

for(inti=0;i<3;i++){

newThread(){
@Override
publicvoidrun(){

while(true){
q.get();


.start();

newThread(){
@Override
publicvoidrun(){
while(true){
q.put(newRandom().nextInt(10000));


.start();




classQueue{

//共享数据,只能有一个线程能写该数据,但可以有多个线程同时读该数据。
ReadWriteLockrwl=newReentrantReadWriteLock();
privateObjectdata=null;//共享数据,只能有一个线程能写数据,但可以有多个线程读该数据

publicvoidget(){
//上读锁,其他线程只能读不能写
rwl.readLock().lock();
try{

System.out.println(Thread.currentThread().getName()+"bereadytoreaddata!");
Thread.sleep((long)(Math.random()*1000));
System.out.println(Thread.currentThread().getName()+"havereaddata:"+data);
catch(InterruptedExceptione){
e.printStackTrace();
finally{
rwl.readLock().unlock();



publicvoidput(Objectdata){
//上写锁,不允许其他线程读也不允许写
rwl.writeLock().lock();

try{
System.out.println(Thread.currentThread().getName()+"bereadytowritedata!");

Thread.sleep((long)(Math.random()*1000));

this.data=data;
System.out.println(Thread.currentThread().getName()+"havewritedata:"+data);
catch(InterruptedExceptione){
e.printStackTrace();
finally{
rwl.writeLock().unlock();