Package com.appslandia.common.threading

Class ConcurrentService

java.lang.Object

com.appslandia.common.base.InitializeObject

com.appslandia.common.threading.ConcurrentService

All Implemented Interfaces:

InitializeSupport

public abstract class ConcurrentService
extends InitializeObject

Author:

Loc Ha

Field Summary

Fields

Modifier and Type	Field	Description
protected Map<Object,Object>	barriers
protected Object	defaultMutex

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

mutex

Constructor Summary

Constructors

Constructor	Description
ConcurrentService()

Method Summary

Modifier and Type	Method	Description
ConcurrentService	addBarrier(Object barrierId)
<V> V	execute(Object barrierId, Callable<V> task)
<V> V	execute(Object barrierId, Callable<V> task, long timeout, TimeUnit unit)
abstract ExecutorService	getExecutorService()
protected Object	getMutex(Object barrierId)

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

assertNotInitialized, destroy, init, initialize

Methods inherited from class java.lang.Object

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

Field Detail

barriers

protected final Map<Object,Object> barriers

defaultMutex

protected final Object defaultMutex

Constructor Detail

ConcurrentService

public ConcurrentService()

Method Detail

getExecutorService

public abstract ExecutorService getExecutorService()

getMutex

protected Object getMutex(Object barrierId)

execute

public <V> V execute(Object barrierId,
                     Callable<V> task)
              throws Exception

Throws:

Exception

execute

public <V> V execute(Object barrierId,
                     Callable<V> task,
                     long timeout,
                     TimeUnit unit)
              throws Exception

Throws:

Exception

addBarrier

public ConcurrentService addBarrier(Object barrierId)