Java多线程 ReentrantReadWriteLock原理及实例详解
读写锁ReentrantReadWriteLock概述
读写锁ReentrantReadWriteLock，使用它比ReentrantLock效率更高。
读写锁表示两个锁，一个是读操作相关的锁，称为共享锁；另一个是写操作相关的锁，称为排他锁。
1、读和读之间不互斥，因为读操作不会有线程安全问题
2、写和写之间互斥，避免一个写操作影响另外一个写操作，引发线程安全问题
3、读和写之间互斥，避免读操作的时候写操作修改了内容，引发线程安全问题
多个Thread可以同时进行读取操作，但是同一时刻只允许一个Thread进行写入操作。
读操作和读操作共享
请看例子
ThreadDomain44类和main方法
publicclassThreadDomain44extendsReentrantReadWriteLock
{
publicvoidread()
{
try
{
readLock().lock();
System.out.println(Thread.currentThread().getName()+"获得了读锁,时间为"+
System.currentTimeMillis());
Thread.sleep(10000);
}
catch(InterruptedExceptione)
{
e.printStackTrace();
}
finally
{
readLock().unlock();
}
}
publicstaticvoidmain(String[]args)
{
finalThreadDomain44td=newThreadDomain44();
RunnablereadRunnable=newRunnable()
{
publicvoidrun()
{
td.read();
}
};
Threadt0=newThread(readRunnable);
Threadt1=newThread(readRunnable);
t0.start();
t1.start();
}
}
输出结果如下
Thread-0获得了读锁,时间为1564018325618 Thread-1获得了读锁,时间为1564018325618
尽管加了Thread.sleep(10000);两个线程几乎同时执行lock()后面的方法。说明readLock().lock()允许多个线程执行并且能提高执行效率。
写操作和写操作互斥
请看例子
publicclassThreadDomain45extendsReentrantReadWriteLock{
publicvoidwrite()
{
try
{
writeLock().lock();
System.out.println(Thread.currentThread().getName()+"获得了写锁,时间为"+
newDate());
Thread.sleep(10000);
}
catch(InterruptedExceptione)
{
e.printStackTrace();
}
finally
{
writeLock().unlock();
}
}
publicstaticvoidmain(String[]args)
{
finalThreadDomain45td=newThreadDomain45();
RunnablereadRunnable=newRunnable()
{
publicvoidrun()
{
td.write();
}
};
Threadt0=newThread(readRunnable);
Threadt1=newThread(readRunnable);
t0.start();
t1.start();
}
}
输出结果
Thread-1获得了写锁,时间为TueJul3011:26:21CST2019 Thread-0获得了写锁,时间为TueJul3011:26:31CST2019
可以看到，后获得锁的Thread-0等待了十秒，说明写和写互斥
读操作和写操作互斥/写操作和读操作互斥
例子如下
publicclassThreadDomain46extendsReentrantReadWriteLock{
publicvoidwrite()
{
try
{
writeLock().lock();
System.out.println(Thread.currentThread().getName()+"获得了写锁,时间为"+
newDate());
Thread.sleep(10000);
}
catch(InterruptedExceptione)
{
e.printStackTrace();
}
finally
{
writeLock().unlock();
}
}
publicvoidread()
{
try
{
readLock().lock();
System.out.println(Thread.currentThread().getName()+"获得了读锁,时间为"+
newDate());
Thread.sleep(10000);
}
catch(InterruptedExceptione)
{
e.printStackTrace();
}
finally
{
readLock().unlock();
}
}
publicstaticvoidmain(String[]args)
{
finalThreadDomain46td=newThreadDomain46();
RunnablereadRunnable=newRunnable()
{
publicvoidrun()
{
td.read();
}
};
RunnablewriteRunnable=newRunnable()
{
publicvoidrun()
{
td.write();
}
};
Threadt0=newThread(readRunnable);
Threadt1=newThread(writeRunnable);
t0.start();
t1.start();
}
}
输出结果如下
Thread-0获得了读锁,时间为TueJul3011:49:15CST2019 Thread-1获得了写锁,时间为TueJul3011:49:26CST2019
可以看到Thread-0获得读锁执行完10s后Thread-1才获得了写锁，说明读操作和写操作互斥。
另一种输出结果如下
Thread-1获得了写锁,时间为TueJul3014:14:07CST2019 Thread-0获得了读锁,时间为TueJul3014:14:17CST2019
可以看到Thread-1获得写锁执行完10s后Thread-0才获得了读锁，说明写操作和读操作互斥。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。