org.apache.hadoop.hbase.util

Class IdReadWriteLock<T>

java.lang.Object

org.apache.hadoop.hbase.util.IdReadWriteLock<T>

@InterfaceAudience.Private
public class IdReadWriteLock<T>
extends Object

Allows multiple concurrent clients to lock on a numeric id with ReentrantReadWriteLock. The intended usage for read lock is as follows:

 ReentrantReadWriteLock lock = idReadWriteLock.getLock(id);
 try {
   lock.readLock().lock();
   // User code.
 } finally {
   lock.readLock().unlock();
 }
 

For write lock, use lock.writeLock()

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	IdReadWriteLock.ReferenceType

Constructor Summary

Constructors

Constructor and Description
IdReadWriteLock()
IdReadWriteLock(IdReadWriteLock.ReferenceType referenceType) Constructor of IdReadWriteLock

Method Summary

Modifier and Type	Method and Description
ReentrantReadWriteLock	getLock(T id) Get the ReentrantReadWriteLock corresponding to the given id
IdReadWriteLock.ReferenceType	getReferenceType()
void	waitForWaiters(T id, int numWaiters)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IdReadWriteLock

public IdReadWriteLock()

IdReadWriteLock

public IdReadWriteLock(IdReadWriteLock.ReferenceType referenceType)

Constructor of IdReadWriteLock

Parameters:

referenceType - type of the reference used in lock pool, IdReadWriteLock.ReferenceType.WEAK by default. Use IdReadWriteLock.ReferenceType.SOFT if the key set is limited and the locks will be reused with a high frequency

Method Detail

getLock

public ReentrantReadWriteLock getLock(T id)

Get the ReentrantReadWriteLock corresponding to the given id

Parameters:

id - an arbitrary number to identify the lock

waitForWaiters

public void waitForWaiters(T id,
                           int numWaiters)
                    throws InterruptedException

Throws:

InterruptedException

getReferenceType

public IdReadWriteLock.ReferenceType getReferenceType()