com.appslandia.common.threading

Class ConcurrentService<K>

java.lang.Object

com.appslandia.common.base.InitializeObject

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

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

All Implemented Interfaces:

InitializeSupport

public abstract class ConcurrentService<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
ConcurrentService()

Method Summary

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

ConcurrentService

public ConcurrentService()

Method Detail

getExecutorService

public abstract ExecutorService getExecutorService()

execute

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

Throws:

Exception