Module com.appslandia.common

Package 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

Constructor Summary

Constructors

Constructor	Description
TaskMutexService()

Method Summary

Modifier and Type	Method	Description
void	execute(K mutexKey, Runnable task)
<V> Future<V>	execute(K mutexKey, Runnable task, V result)
<V> Future<V>	execute(K mutexKey, Callable<V> task)
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