org.apache.oozie.lock

Class MemoryLocks

java.lang.Object

org.apache.oozie.lock.MemoryLocks

public class MemoryLocks
extends Object

In memory resource locking that provides READ/WRITE lock capabilities.

Constructor Summary

Constructors

Constructor and Description
MemoryLocks()

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.oozie.lock.MemoryLocks.MemoryLockToken	getLock(String resource, MemoryLocksService.Type type, long wait) Obtain a lock for a source.
ConcurrentMap<String,ReentrantReadWriteLock>	getLockMap()
int	size() Return the number of active locks.

Methods inherited from class java.lang.Object

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

Constructor Detail

MemoryLocks

public MemoryLocks()

Method Detail

size

public int size()

Return the number of active locks.

Returns:

the number of active locks.

getLock

public org.apache.oozie.lock.MemoryLocks.MemoryLockToken getLock(String resource,
                                                        MemoryLocksService.Type type,
                                                        long wait)
                                                          throws InterruptedException

Obtain a lock for a source.

Parameters:

resource - resource name.

type - lock type.

wait - time out in milliseconds to wait for the lock, -1 means no timeout and 0 no wait.

Returns:

the lock token for the resource, or null if the lock could not be obtained.

Throws:

InterruptedException - thrown if the thread was interrupted while waiting.

getLockMap

public ConcurrentMap<String,ReentrantReadWriteLock> getLockMap()