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通过卖票理解多线程等,有什么问题可以随时留言,小编会及时回复大家的。感谢朋友们对毛票票网站的支持。