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

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	Description
TaskMutexService()

Method Summary

Modifier and Type	Method	Description
void	execute(K mutexKey, java.lang.Runnable task)
<V> java.util.concurrent.Future<V>	execute(K mutexKey, java.lang.Runnable task, V result)
<V> java.util.concurrent.Future<V>	execute(K mutexKey, java.util.concurrent.Callable<V> task)
protected abstract java.util.concurrent.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 java.util.concurrent.ExecutorService getExecutorService()

execute

public <V> java.util.concurrent.Future<V> execute(K mutexKey,
                                                  java.util.concurrent.Callable<V> task)
                                           throws java.lang.Exception

Throws:

java.lang.Exception

execute

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

Throws:

java.lang.Exception

execute

public <V> java.util.concurrent.Future<V> execute(K mutexKey,
                                                  java.lang.Runnable task,
                                                  V result)
                                           throws java.lang.Exception

Throws:

java.lang.Exception