Package org.apache.hadoop.hbase.util

Class IdLock

java.lang.Object

org.apache.hadoop.hbase.util.IdLock

@Private
public class IdLock
extends Object

Allows multiple concurrent clients to lock on a numeric id with a minimal memory overhead. The intended usage is as follows:

 IdLock.Entry lockEntry = idLock.getLockEntry(id);
 try {
   // User code.
 } finally {
   idLock.releaseLockEntry(lockEntry);
 }
 

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	IdLock.Entry	An entry returned to the client as a lock object

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG
private ConcurrentMap<Long,IdLock.Entry>	map

Constructor Summary

Constructors

Constructor	Description
IdLock()

Method Summary

Modifier and Type	Method	Description
(package private) void	assertMapEmpty()
IdLock.Entry	getLockEntry(long id)	Blocks until the lock corresponding to the given id is acquired.
boolean	isHeldByCurrentThread(long id)	Test whether the given id is already locked by the current thread.
void	releaseLockEntry(IdLock.Entry entry)	Must be called in a finally block to decrease the internal counter and remove the monitor object for the given id if the caller is the last client.
IdLock.Entry	tryLockEntry(long id, long time)	Blocks until the lock corresponding to the given id is acquired.
void	waitForWaiters(long id, int numWaiters)

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

map

private ConcurrentMap<Long,IdLock.Entry> map

Constructor Details

IdLock

public IdLock()

Method Details

getLockEntry

public IdLock.Entry getLockEntry(long id)
                          throws IOException

Blocks until the lock corresponding to the given id is acquired.

Parameters:

id - an arbitrary number to lock on

Returns:

an "entry" to pass to releaseLockEntry(Entry) to release the lock

Throws:

IOException - if interrupted

tryLockEntry

public IdLock.Entry tryLockEntry(long id,
 long time)
                          throws IOException

Blocks until the lock corresponding to the given id is acquired.

Parameters:

id - an arbitrary number to lock on

time - time to wait in ms

Returns:

an "entry" to pass to releaseLockEntry(Entry) to release the lock

Throws:

IOException - if interrupted

releaseLockEntry

public void releaseLockEntry(IdLock.Entry entry)

Must be called in a finally block to decrease the internal counter and remove the monitor object for the given id if the caller is the last client.

Parameters:

entry - the return value of getLockEntry(long)

isHeldByCurrentThread

public boolean isHeldByCurrentThread(long id)

Test whether the given id is already locked by the current thread.

assertMapEmpty

void assertMapEmpty()

waitForWaiters

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

Throws:

InterruptedException