互斥锁ReentrantLock

kanwoerzi

浏览: 1647734 次

最近访客更多访客>>

u012363178

lynnlysh

zyysal

aaron198

博主相关

博客

微博

相册

留言

关于我

文章分类

全部博客 (1724)

社区版块

存档分类

2011-12 ( 292)
2011-11 ( 349)
2011-10 ( 284)
更多存档...

publicclassReentrantLock extendsObject implementsLock,Serializable 一个可重入的互斥锁Lock，它具有与使用synchronized方法和语句所访问的隐式监视器锁相同的一些基本行为和语义，但功能更强大。 ReentrantLock将由最近成功获得锁，并且还没有释放该锁的线程所拥有。当锁没有被另一个线程所拥有时， 调用lock的线程将成功获取该锁并返回。如果当前线程已经拥有该锁，此方法将立即返回。 可以使用isHeldByCurrentThread()和getHoldCount()方法来检查此情况是否发生。 此类的构造方法接受一个可选的公平参数。当设置为true时，在多个线程的争用下， 这些锁倾向于将访问权授予等待时间最长的线程。否则此锁将无法保证任何特定访问顺序。 与采用默认设置（使用不公平锁）相比，使用公平锁的程序在许多线程访问时表现为很低的总体吞吐量（即速度很慢，常常极其慢）， 但是在获得锁和保证锁分配的均衡性时差异较小。不过要注意的是，公平锁不能保证线程调度的公平性。 因此，使用公平锁的众多线程中的一员可能获得多倍的成功机会，这种情况发生在其他活动线程没有被处理并且目前并未持有锁时。 还要注意的是，未定时的tryLock方法并没有使用公平设置。因为即使其他线程正在等待，只要该锁是可用的，此方法就可以获得成功。 建议总是立即实践，使用lock块来调用try，在之前/之后的构造中，最典型的代码如下： classX{ privatefinalReentrantLocklock=newReentrantLock(); //... publicvoidm(){ lock.lock();//blockuntilconditionholds try{ //...methodbody }finally{ lock.unlock() } } } 除了实现Lock接口，此类还定义了isLocked和getLockQueueLength方法，以及一些相关的protected访问方法， 这些方法对检测和监视可能很有用。 该类的序列化与内置锁的行为方式相同：一个反序列化的锁处于解除锁定状态，不管它被序列化时的状态是怎样的。 此锁最多支持同一个线程发起的2147483648个递归锁。试图超过此限制会导致由锁方法抛出的Error。 注意1:此类的构造方法接受一个可选的公平参数。当设置为true时，在多个线程的争用下， 这些锁倾向于将访问权授予等待时间最长的线程。否则此锁将无法保证任何特定访问顺序。但是公平锁不能保证线程调度的公平性。 因此，使用公平锁的众多线程中的一员可能获得多倍的成功机会。 注意2:此锁是个递归锁。此锁最多支持同一个线程发起的2147483648个递归锁。关于递归锁的问题可参照《可递归锁与非递归锁》 主要函数： publicvoidlock() 获取锁。 如果该锁没有被另一个线程保持，则获取该锁并立即返回，将锁的保持计数设置为1。 如果当前线程已经保持该锁，则将保持计数加1，并且该方法立即返回。 如果该锁被另一个线程保持，则出于线程调度的目的，禁用当前线程，并且在获得锁之前，该线程将一直处于休眠状态，此时锁保持计数被设置为1。 指定者： 接口Lock中的lock 注意1："如果该锁没有被另一个线程保持，则获取该锁并立即返回，将锁的保持计数设置为1。 如果当前线程已经保持该锁，则将保持计数加1，并且该方法立即返回。" 这样就实现了递归锁. publicvoidlockInterruptibly() throwsInterruptedException 如果当前线程未被中断，则获取锁。 如果该锁没有被另一个线程保持，则获取该锁并立即返回，将锁的保持计数设置为1。 如果当前线程已经保持此锁，则将保持计数加1，并且该方法立即返回。 如果锁被另一个线程保持，则出于线程调度目的，禁用当前线程，并且在发生以下两种情况之一以前，该线程将一直处于休眠状态： *锁由当前线程获得；或者 *其他某个线程中断当前线程。 如果当前线程获得该锁，则将锁保持计数设置为1。 如果当前线程： *在进入此方法时已经设置了该线程的中断状态；或者 *在等待获取锁的同时被中断。 则抛出InterruptedException，并且清除当前线程的已中断状态。 在此实现中，因为此方法是一个显式中断点，所以要优先考虑响应中断，而不是响应锁的普通获取或重入获取。 指定者： 接口Lock中的lockInterruptibly 抛出： InterruptedException-如果当前线程已中断。 注意：它会抛出InterruptedException。 关于InterruptedException更多知识请参阅《<a title="阅读全文" target="_blank" href="http://hubingforever.blog.163.com/blog/static/17104057920108154244111/" style="color:rgb(207,121,28); line-height:25px; text-decoration:none">JAVA线程的interrupt</a>》。 publicbooleantryLock() 仅在调用时锁未被另一个线程保持的情况下，才获取该锁。 如果该锁没有被另一个线程保持，并且立即返回true值，则将锁的保持计数设置为1。 即使已将此锁设置为使用公平排序策略，但是调用tryLock()仍将立即获取锁（如果有可用的）， 而不管其他线程当前是否正在等待该锁。在某些情况下，此“闯入”行为可能很有用，即使它会打破公平性也如此。 如果希望遵守此锁的公平设置，则使用tryLock(0,TimeUnit.SECONDS)，它几乎是等效的（也检测中断）。 如果当前线程已经保持此锁，则将保持计数加1，该方法将返回true。 如果锁被另一个线程保持，则此方法将立即返回false值。 指定者： 接口Lock中的tryLock 返回： 如果锁是自由的并且被当前线程获取，或者当前线程已经保持该锁，则返回true；否则返回false 注意1：该方法不会阻塞，它也不一定能得到锁。如果得到返回ture，否则false. 注意2：即使已将此锁设置为使用公平排序策略，但是调用tryLock()仍将立即获取锁（如果有可用的）， 而不管其他线程当前是否正在等待该锁。这样看来他获得锁的优先级比正被阻塞的lock()方法高。 publicbooleantryLock(longtimeout, TimeUnitunit) throwsInterruptedException 如果锁在给定等待时间内没有被另一个线程保持，且当前线程未被中断，则获取该锁。 如果该锁没有被另一个线程保持，并且立即返回true值，则将锁的保持计数设置为1。 如果为了使用公平的排序策略，已经设置此锁，并且其他线程都在等待该锁，则不会获取一个可用的锁。 这与tryLock()方法相反。如果想使用一个允许闯入公平锁的定时tryLock，那么可以将定时形式和不定时形式组合在一起： if(lock.tryLock()||lock.tryLock(timeout,unit)){...} 如果当前线程已经保持此锁，则将保持计数加1，该方法将返回true。 如果锁被另一个线程保持，则出于线程调度目的，禁用当前线程，并且在发生以下三种情况之一以前，该线程将一直处于休眠状态： *锁由当前线程获得；或者 *其他某个线程中断当前线程；或者 *已超过指定的等待时间 如果获得该锁，则返回true值，并将锁保持计数设置为1。 如果当前线程： *在进入此方法时已经设置了该线程的中断状态；或者 *在等待获取锁的同时被中断。 则抛出InterruptedException，并且清除当前线程的已中断状态。 如果超出了指定的等待时间，则返回值为false。如果该时间小于等于0，则此方法根本不会等待。 在此实现中，因为此方法是一个显式中断点，所以要优先考虑响应中断，而不是响应锁的普通获取或重入获取，或者报告所用的等待时间。 指定者： 接口Lock中的tryLock 参数： timeout-等待锁的时间 unit-timeout参数的时间单位 返回： 如果锁是自由的并且由当前线程获取，或者当前线程已经保持该锁，则返回true；如果在获取该锁之前已经到达等待时间，则返回false 抛出： InterruptedException-如果当前线程被中断 NullPointerException-如果时间单位为null 注意1：如果为了使用公平的排序策略，已经设置此锁，并且其他线程都在等待该锁， 则不会获取一个可用的锁。这与tryLock()方法相反 注意2：它会抛出InterruptedException。 关于InterruptedException更多知识请参阅《<a title="阅读全文" target="_blank" href="http://hubingforever.blog.163.com/blog/static/17104057920108154244111/" style="color:rgb(207,121,28); line-height:25px; text-decoration:none">JAVA线程的interrupt</a>》。 publicvoidunlock() 试图释放此锁。 如果当前线程是此锁所有者，则将保持计数减1。如果保持计数现在为0，则释放该锁。 如果当前线程不是此锁的持有者，则抛出IllegalMonitorStateException。 指定者： 接口Lock中的unlock 抛出： IllegalMonitorStateException-如果当前线程没有保持此锁 注意1："如果当前线程是此锁所有者，则将保持计数减1。如果保持计数现在为0，则释放该锁。"这样就实现了递归锁. 下面两个是对于调试和测试很有用的方法。 publicintgetHoldCount() 查询当前线程保持此锁的次数。 对于与解除锁操作不匹配的每个锁操作，线程都会保持一个锁。 保持计数信息通常只用于测试和调试。例如，如果不应该使用已经保持的锁进入代码的某一部分，则可以声明如下： classX{ ReentrantLocklock=newReentrantLock(); //... publicvoidm(){ assertlock.getHoldCount()==0; lock.lock(); try{ //...methodbody }finally{ lock.unlock(); } } } 返回： 当前线程保持此锁的次数，如果此锁未被当前线程保持过，则返回0 publicbooleanisHeldByCurrentThread() 查询当前线程是否保持此锁。 与内置监视器锁的Thread.holdsLock(java.lang.Object)方法类似，此方法通常用于调试和测试。 例如，只在保持某个锁时才应调用的方法可以声明如下： classX{ ReentrantLocklock=newReentrantLock(); //... publicvoidm(){ assertlock.isHeldByCurrentThread(); //...methodbody } } 还可以用此方法来确保某个重入锁是否以非重入方式使用的，例如： classX{ ReentrantLocklock=newReentrantLock(); //... publicvoidm(){ assert!lock.isHeldByCurrentThread(); lock.lock(); try{ //...methodbody }finally{ lock.unlock(); } } } 返回： 如果当前线程保持此锁，则返回true；否则返回false publicConditionnewCondition() 返回用来与此Lock实例一起使用的Condition实例。 在使用内置监视器锁时，返回的Condition实例支持与Object的监视器方法（wait、notify和notifyAll）相同的用法。 *在调用Condition、waiting或signalling这些方法中的任意一个方法时，如果没有保持此锁，则将抛出IllegalMonitorStateException。 *在调用waiting条件方法时，将释放锁，并在这些方法返回之前，重新获取该锁，将锁保持计数恢复为调用方法时所持有的值。 *如果线程在等待时被中断，则等待将终止，并将抛出InterruptedException，清除线程的中断状态。 *等待线程按FIFO顺序收到信号。 *等待方法返回的线程重新获取锁的顺序与线程最初获取锁的顺序相同，在默认情况下，未指定此顺序，但对于公平锁，它们更倾向于那些等待时间最长的线程。 指定者： 接口Lock中的newCondition 返回： Condition对象 注意：关于Condition的更多知识和使用请参阅《<a title="阅读全文" target="_blank" href="http://hubingforever.blog.163.com/blog/static/171040579201082812035668/" style="color:rgb(207,121,28); line-height:25px; text-decoration:none">Condition</a>》。 Lock的使用很简单，见实例1。关于Lock的Condition使用请查阅《<a title="阅读全文" target="_blank" href="http://hubingforever.blog.163.com/blog/static/171040579201082812035668/" style="color:rgb(207,121,28); line-height:25px; text-decoration:none">Condition</a>》 实例1: staticvoidLockDemo() { Countercounter=newCounter(); System.out.println("initvalue:"+counter.getValue()); counter.increment(); System.out.println("thevalue:"+counter.getValue()); counter.decrement(); counter.decrement(); counter.decrement(); System.out.println("thevalue:"+counter.getValue()); } } classCounter{ privateintvalue; privatefinalReentrantLocklock=newReentrantLock(); publicintgetValue() { lock.lock(); try{ returnvalue; }finally { lock.unlock(); System.out.println("thehodecountoflockis:"+lock.getHoldCount()); } } publicintincrement() { lock.lock(); try{ return++value; }finally { lock.unlock(); } } publicintdecrement(){ lock.lock(); try{ return--value; }finally { lock.unlock(); } } }

分享到：