com.gemstone.gemfire

Class CancelCriterion

java.lang.Object

com.gemstone.gemfire.CancelCriterion

public abstract class CancelCriterion
extends Object

Abstract cancellation proxy for cancelling an operation, esp. a thread. Creators of services or threads should implement a subclass of CancelCriterion, and implement the two methods - cancelInProgress, and generateCancelledException(e). Code inside the service can check to see if the service is cancelled by calling checkCancelInProgress(Throwable). Generally the pattern is to check before performing an operation, check if the service is canceled before propgrating an exception futher up the stack, and check for cancelation inside a long loop. Eg. while(true) { c.checkCancelInProgress(null); try { dispatchEvents(); } catch(IOException e) { c.checkCancelInProgress(e); throw e; } }

Since:

5.1

See Also:

CancelException

Constructor Summary

Constructors

Constructor and Description
CancelCriterion()

Method Summary

Methods

Modifier and Type	Method and Description
abstract String	cancelInProgress() Indicate if the service is in the progress of being cancelled.
void	checkCancelInProgress(Throwable e) See if the current operation is being cancelled.
abstract RuntimeException	generateCancelledException(Throwable e) Template factory method for generating the exception to be thrown by checkCancelInProgress(Throwable).

Methods inherited from class java.lang.Object

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

Constructor Detail

CancelCriterion

public CancelCriterion()

Method Detail

cancelInProgress

public abstract String cancelInProgress()

Indicate if the service is in the progress of being cancelled. The typical use of this is to indicate, in the case of an InterruptedException, that the current operation should be cancelled.

Returns:

null if the service is not shutting down, or a message that can be used to construct an exception indicating the service is shut down.

checkCancelInProgress

public final void checkCancelInProgress(Throwable e)

See if the current operation is being cancelled. If so, it either throws a RuntimeException (usually a CancelException).

Parameters:

e - an underlying exception or null if there is no exception that triggered this check

See Also:

cancelInProgress()

generateCancelledException

public abstract RuntimeException generateCancelledException(Throwable e)

Template factory method for generating the exception to be thrown by checkCancelInProgress(Throwable). Override this to specify different exception for checkCancelInProgress() to throw. This method should wrap the exception in a service specific CancelationException (eg CacheClosedException). or return null if the service is not being canceled.

Parameters:

e - an underlying exception, if any

Returns:

RuntimeException to be thrown by checkCancelInProgress(), null if the receiver has not been cancelled.