Java多线程之readwritelock读写分离的实现代码
在多线程开发中，经常会出现一种情况，我们希望读写分离。就是对于读取这个动作来说，可以同时有多个线程同时去读取这个资源，但是对于写这个动作来说，只能同时有一个线程来操作，而且同时，当有一个写线程在操作这个资源的时候，其他的读线程是不能来操作这个资源的，这样就极大的发挥了多线程的特点，能很好的将多线程的能力发挥出来。
在Java中，ReadWriteLock这个接口就为我们实现了这个需求，通过他的实现类ReentrantReadWriteLock我们可以很简单的来实现刚才的效果，下面我们使用一个例子来说明这个类的用法。
packagecom.bird.concursey.charpet3;
importjava.util.concurrent.locks.ReadWriteLock;
importjava.util.concurrent.locks.ReentrantReadWriteLock;
publicclassPricesInfo{
privatedoubleprice1;
privatedoubleprice2;
privateReadWriteLocklock;
publicPricesInfo(){
price1=1.0;
price2=2.0;
lock=newReentrantReadWriteLock();
}
publicdoublegetPrice1(){
//读取资源锁定
lock.readLock().lock();
doublevalue=price1;
lock.readLock().unlock();
returnvalue;
}
publicdoublegetPrice2(){
lock.readLock().lock();
doublevalue=price2;
lock.readLock().unlock();
returnvalue;
}
publicvoidsetPrices(doubleprice1,doubleprice2){
lock.writeLock().lock();
this.price1=price1;
this.price2=price2;
lock.writeLock().unlock();
}
}
下面是读和写两个不同的类
packagecom.bird.concursey.charpet3;
publicclassReaderimplementsRunnable{
privatePricesInfopricesInfo;
publicReader(PricesInfopricesInfo){
this.pricesInfo=pricesInfo;
}
@Override
publicvoidrun(){
for(inti=0;i<10;i++){
System.out.printf("%s:Price1:%f\n",Thread.currentThread()
.getName(),pricesInfo.getPrice1());
System.out.printf("%s:Price2:%f\n",Thread.currentThread()
.getName(),pricesInfo.getPrice2());
}
}
}
packagecom.bird.concursey.charpet3;
publicclassWriterimplementsRunnable{
privatePricesInfopricesInfo;
publicWriter(PricesInfopricesInfo){
this.pricesInfo=pricesInfo;
}
@Override
publicvoidrun(){
for(inti=0;i<3;i++){
System.out.printf("Writer:Attempttomodifytheprices.\n");
pricesInfo.setPrices(Math.random()*10,Math.random()*8);
System.out.printf("Writer:Priceshavebeenmodified.\n");
try{
Thread.sleep(2);
}catch(InterruptedExceptione){
e.printStackTrace();
}
}
}
publicstaticvoidmain(String[]args){
PricesInfopricesInfo=newPricesInfo();
Readerreaders[]=newReader[5];
ThreadthreadsReader[]=newThread[5];
for(inti=0;i<5;i++){
readers[i]=newReader(pricesInfo);
threadsReader[i]=newThread(readers[i]);
}
Writerwriter=newWriter(pricesInfo);
ThreadthreadWriter=newThread(writer);
for(inti=0;i<5;i++){
threadsReader[i].start();
}
threadWriter.start();
}
}
总结
以上就是本文关于Java多线程之readwritelock读写分离的实现代码的全部内容，希望对大家有所帮助。感兴趣的朋友可以参阅：Java多线程阻塞与唤醒代码示例 、Java多线程ForkJoinPool实例详解 、详解java中的互斥锁信号量和多线程等待机制 、Java通过卖票理解多线程等，有什么问题可以随时留言，小编会及时回复大家的。感谢朋友们对毛票票网站的支持。