com.bigdata.concurrent

Class FutureTaskMon<T>

java.lang.Object

java.util.concurrent.FutureTask<T>

com.bigdata.concurrent.FutureTaskMon<T>

All Implemented Interfaces:

Runnable, Future<T>, RunnableFuture<T>

Direct Known Subclasses:

FutureTaskInvariantMon, NonBlockingLockManager.LockFutureTask, NonBlockingLockManagerWithNewDesign.LockFutureTask

public class FutureTaskMon<T>
extends FutureTask<T>

This is a flyweight utility class to be used as a direct replacement for FutureTask in code where we may need to be able to discover the root cancel request causing an interrupt.

Author:

Martyn Cutcher

Constructor Summary

Constructors

Constructor and Description
FutureTaskMon(Callable<T> callable)
FutureTaskMon(Runnable runnable, T result)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	cancel(boolean mayInterruptIfRunning)
void	run()

Methods inherited from class java.util.concurrent.FutureTask

done, get, get, isCancelled, isDone, runAndReset, set, setException

Methods inherited from class java.lang.Object

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

Constructor Detail

FutureTaskMon

public FutureTaskMon(Callable<T> callable)

FutureTaskMon

public FutureTaskMon(Runnable runnable,
             T result)

Method Detail

run

public void run()

Hooked to notice when the task has been started.

Specified by:

run in interface Runnable

Specified by:

run in interface RunnableFuture<T>

Overrides:

run in class FutureTask<T>

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Overridden to conditionally log @ DEBUG if the caller caused the task to be interrupted. This can be used to search for sources of interrupts.

Specified by:

cancel in interface Future<T>

Overrides:

cancel in class FutureTask<T>