Package com.oracle.coherence.concurrent.executor

Class ClusteredExecutorInfo.ClosingContinuation

java.lang.Object

com.oracle.coherence.concurrent.executor.ClusteredExecutorInfo.CacheAwareContinuation

com.oracle.coherence.concurrent.executor.ClusteredExecutorInfo.ClosingContinuation

All Implemented Interfaces:

Continuation<Object>, ComposableContinuation

Enclosing class:

ClusteredExecutorInfo

public static class ClusteredExecutorInfo.ClosingContinuation
extends ClusteredExecutorInfo.CacheAwareContinuation

A ComposableContinuation to close a ClusteredExecutorInfo, including cleaning up assigned Tasks.

Field Summary

Fields

Modifier and Type	Field	Description
protected String	f_sExecutorId	The unique identity of the Executor.

Fields inherited from class com.oracle.coherence.concurrent.executor.ClusteredExecutorInfo.CacheAwareContinuation

f_cacheService

Constructor Summary

Constructors

Constructor	Description
ClosingContinuation(String sExecutorId, CacheService cacheService)	Constructs an ClusteredExecutorInfo.ClosingContinuation.

Method Summary

Modifier and Type	Method	Description
ComposableContinuation	compose(ComposableContinuation continuation)	Composes this ComposableContinuation with the specified ComposableContinuation to produce a ComposableContinuation that replaces the need for this and the specified ComposableContinuation.
void	proceed(Object o)	Resume the execution after the completion of an asynchronous call.

Methods inherited from class com.oracle.coherence.concurrent.executor.ClusteredExecutorInfo.CacheAwareContinuation

assignments, executors, tasks

Methods inherited from class java.lang.Object

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

Field Detail

f_sExecutorId

protected final String f_sExecutorId

The unique identity of the Executor.

Constructor Detail

ClosingContinuation

public ClosingContinuation(String sExecutorId,
                           CacheService cacheService)

Constructs an ClusteredExecutorInfo.ClosingContinuation.

Parameters:

sExecutorId - the Executor identity to update

cacheService - the CacheService

Method Detail

proceed

public void proceed(Object o)

Description copied from interface: Continuation

Resume the execution after the completion of an asynchronous call.

Parameters:

o - the result of the execution preceding this continuation

compose

public ComposableContinuation compose(ComposableContinuation continuation)

Description copied from interface: ComposableContinuation

Composes this ComposableContinuation with the specified ComposableContinuation to produce a ComposableContinuation that replaces the need for this and the specified ComposableContinuation.

Parameters:

continuation - the ComposableContinuation to compose

Returns:

the composed ComposableContinuation