com.appslandia.common.threading

Class TaskMutexService<K>

java.lang.Object

com.appslandia.common.base.InitializeObject

com.appslandia.common.threading.MutexService<K>

com.appslandia.common.threading.TaskMutexService<K>

All Implemented Interfaces:

InitializeSupport

public abstract class TaskMutexService<K>
extends MutexService<K>

Author:

Loc Ha

Field Summary

Fields inherited from class com.appslandia.common.threading.MutexService

mutexMap

Fields inherited from class com.appslandia.common.base.InitializeObject

mutex

Constructor Summary

Constructors

Constructor and Description
TaskMutexService()

Method Summary

Modifier and Type	Method and Description
<V> Future<V>	execute(K mutexKey, Callable<V> task)
void	execute(K mutexKey, Runnable task)
<V> Future<V>	execute(K mutexKey, Runnable task, V result)
protected abstract ExecutorService	getExecutorService()

Methods inherited from class com.appslandia.common.threading.MutexService

getMutex, init

Methods inherited from class com.appslandia.common.base.InitializeObject

assertNotInitialized, destroy, initialize

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskMutexService

public TaskMutexService()

Method Detail

getExecutorService

protected abstract ExecutorService getExecutorService()

execute

public <V> Future<V> execute(K mutexKey,
                             Callable<V> task)
                      throws Exception

Throws:

Exception

execute

public void execute(K mutexKey,
                    Runnable task)
             throws Exception

Throws:

Exception

execute

public <V> Future<V> execute(K mutexKey,
                             Runnable task,
                             V result)
                      throws Exception

Throws:

Exception