com.sun.sgs.impl.nio
Class Reactor.AsyncOp<R>

java.lang.Object
  java.util.concurrent.FutureTask<R>
      com.sun.sgs.impl.nio.Reactor.AsyncOp<R>

Type Parameters:

R - the result type

All Implemented Interfaces:

Runnable, Future<R>, RunnableFuture<R>

Enclosing class:

Reactor

static class Reactor.AsyncOp<R>
extends FutureTask<R>

A FutureTask that can be canceled by a timeout exception.

Constructor Summary

Reactor.AsyncOp(Callable<R> callable)
Creates a new instance.

Method Summary

(package private) void

timeoutExpired() Completes this future as if its run() method threw an AbortedByTimeoutException, unless this future has already completed.

Methods inherited from class java.util.concurrent.FutureTask

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

Methods inherited from class java.lang.Object

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

Constructor Detail

Reactor.AsyncOp

Reactor.AsyncOp(Callable<R> callable)

Creates a new instance.

Parameters:

callable - the work to perform when this task is run

Method Detail

timeoutExpired

void timeoutExpired()

Completes this future as if its run() method threw an AbortedByTimeoutException, unless this future has already completed.