Package com.oracle.coherence.concurrent.executor

Class ContinuationService<T>

java.lang.Object

com.oracle.coherence.concurrent.executor.ContinuationService<T>

Type Parameters:

T - a type

public class ContinuationService<T>
extends Object

A service for tracking, composing and executing ComposableContinuations.

Since:

21.12

Author:

Brian Oliver

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	ContinuationService.ContinuationRunnable	The Runnable that will execute a ComposableContinuation for an Object using a specified ExecutorService index.

Field Summary

Fields

Modifier and Type	Field	Description
protected ExecutorService[]	f_aContinuationServices	The ExecutorServices for executing ComposableContinuations.
protected ConcurrentHashMap<T,ComposableContinuation>	f_mapPendingContinuations	The map of pending ComposableContinuations by object.
protected AtomicEnum<com.oracle.coherence.concurrent.executor.ContinuationService.State>	f_state	The current ContinuationService.State of the ContinuationService.

Constructor Summary

Constructors

Constructor	Description
ContinuationService(ThreadFactory threadFactory)	Construct a ContinuationService using the specified ThreadFactory to provide Threads for executing ComposableContinuations.

Method Summary

Modifier and Type	Method	Description
void	abandon(T object)	Abandons any ComposableContinuations for the specified object.
void	shutdown()	Initiates an orderly shutdown in which previously submitted ComposableContinuations are allowed to execute, but no new ComposableContinuations may be executed.
void	shutdownNow()	Attempts the shutdown of the ContinuationService immediately, abandoning any submitted ComposableContinuations and interrupting those that are running.
boolean	submit(ComposableContinuation continuation, T object)	Schedule a ComposableContinuation to be asynchronously executed for the specified object.

Methods inherited from class java.lang.Object

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

Field Detail

f_mapPendingContinuations

protected final ConcurrentHashMap<T,ComposableContinuation> f_mapPendingContinuations

The map of pending ComposableContinuations by object.

f_aContinuationServices

protected final ExecutorService[] f_aContinuationServices

The ExecutorServices for executing ComposableContinuations.

f_state

protected final AtomicEnum<com.oracle.coherence.concurrent.executor.ContinuationService.State> f_state

The current ContinuationService.State of the ContinuationService.

Constructor Detail

ContinuationService

public ContinuationService(ThreadFactory threadFactory)

Construct a ContinuationService using the specified ThreadFactory to provide Threads for executing ComposableContinuations.

Parameters:

threadFactory - the ThreadFactory

Method Detail

submit

public boolean submit(ComposableContinuation continuation,
                      T object)

Schedule a ComposableContinuation to be asynchronously executed for the specified object.

Parameters:

continuation - the ComposableContinuation

object - the object

Returns:

true if the ComposableContinuation was accepted false if the ComposableContinuation was rejected (due to the service being unavailable or the continuation being invalid ie: null)

abandon

public void abandon(T object)

Abandons any ComposableContinuations for the specified object.

Parameters:

object - the object

shutdown

public void shutdown()

Initiates an orderly shutdown in which previously submitted ComposableContinuations are allowed to execute, but no new ComposableContinuations may be executed.

This method does not wait for previously submitted tasks to complete execution. Use awaitTermination to do that.

shutdownNow

public void shutdownNow()

Attempts the shutdown of the ContinuationService immediately, abandoning any submitted ComposableContinuations and interrupting those that are running.

This method does not wait for previously submitted tasks to complete execution. Use awaitTermination to do that.