Class NfsMutexActor

java.lang.Object

org.tasktide.mutex.actor.InterProcessMutexActor

org.tasktide.mutex.actor.NfsMutexActor

All Implemented Interfaces:

MutexActor

public class NfsMutexActor
extends InterProcessMutexActor

Package private implementation of the InterProcessMutexActor for shared file system

Field Summary

Fields inherited from class InterProcessMutexActor

JSON, PRETTY_JSON

Constructor Summary

Constructors

Constructor	Description
NfsMutexActor()

Method Summary

Modifier and Type	Method	Description
boolean	acquire(Path targetFile)	Acquire lock for provided target file
boolean	acquire(Mutex mutex)	Acquire lock for provided Mutex
Mutex	fetchActiveFieldValue()	Provides the value for the active Mutex
MutexState	getState()	Get mutex state
MutexStrategy	getStrategy()	Get MutexStrategy
boolean	release()	Release active Mutex if present
boolean	release(Path targetFile)	Release lock on target file
boolean	release(Mutex mutex)	Release provided Mutex
void	setState(MutexState newState)	Set Mutex state
void	waitForLock(Mutex mutex)	Waits for provided Mutex to become the leader

Methods inherited from class InterProcessMutexActor

handleFirstInstance

Methods inherited from class Object

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

Constructor Details

NfsMutexActor

public NfsMutexActor()

Method Details

getStrategy

public MutexStrategy getStrategy()

Get MutexStrategy

Returns:

ElectionStrategy

waitForLock

public void waitForLock(Mutex mutex)
                 throws MutexCheckedException

Waits for provided Mutex to become the leader

Parameters:

mutex -

Throws:

MutexCheckedException

acquire

public boolean acquire(Mutex mutex)
                throws MutexCheckedException

Acquire lock for provided Mutex

Parameters:

mutex -

Returns:

boolean

Throws:

MutexCheckedException

acquire

public boolean acquire(Path targetFile)
                throws MutexCheckedException

Acquire lock for provided target file

Parameters:

targetFile -

Returns:

boolean

Throws:

MutexCheckedException

release

public boolean release(Path targetFile)
                throws MutexCheckedException

Release lock on target file

Parameters:

targetFile -

Returns:

boolean

Throws:

MutexCheckedException

release

public boolean release(Mutex mutex)
                throws MutexCheckedException

Release provided Mutex

Parameters:

mutex -

Returns:

boolean

Throws:

MutexCheckedException

release

public boolean release()
                throws MutexCheckedException

Release active Mutex if present

Returns:

boolean

Throws:

MutexCheckedException

getState

public MutexState getState()

Get mutex state

Returns:

MutexState

setState

public void setState(MutexState newState)

Set Mutex state

Parameters:

newState -

fetchActiveFieldValue

public Mutex fetchActiveFieldValue()

Provides the value for the active Mutex

Returns:

Mutex