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 class ConcurrentService
extends InitializeObject

Author:

Loc Ha

Field Summary

Fields

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

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)
protected void	init()
ConcurrentService	setExecutorService(ExecutorService executorService)

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

Field Detail

barriers

protected final Map<Object,Object> barriers

executorService

protected ExecutorService executorService

Constructor Detail

ConcurrentService

public ConcurrentService()

Method Detail

init

protected void init()
             throws Exception

Specified by:

init in class InitializeObject

Throws:

Exception

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)

setExecutorService

public ConcurrentService setExecutorService(ExecutorService executorService)