Package io.deephaven.enterprise.niowrapper.sched

Class FutureJob<RESULT_TYPE>

java.lang.Object

io.deephaven.enterprise.comm.sched.Job

io.deephaven.enterprise.niowrapper.sched.TimedJob

io.deephaven.enterprise.niowrapper.sched.FutureJob<RESULT_TYPE>

All Implemented Interfaces:

com.fishlib.base.log.LogOutputAppendable, Future<RESULT_TYPE>

public class FutureJob<RESULT_TYPE>
extends TimedJob
implements Future<RESULT_TYPE>

Created by rcaudy on 6/6/14.

Constructor Summary

Constructors

Constructor	Description
FutureJob(Runnable runnable)
FutureJob(Callable<RESULT_TYPE> callable)

Method Summary

Modifier and Type	Method	Description
boolean	cancel(boolean mayInterruptIfRunning)
void	cancelled()	This method is called if the job is explicitly cancelled before it becomes ready or times out.
RESULT_TYPE	get()
RESULT_TYPE	get(long timeout, @NotNull TimeUnit unit)
boolean	isCancelled()
boolean	isDone()
void	timedOut()	This method is invoked if the job times out.

Methods inherited from class io.deephaven.enterprise.niowrapper.sched.TimedJob

append, invoke

Methods inherited from class io.deephaven.enterprise.comm.sched.Job

getStateFor, makeStateFor

Methods inherited from class java.lang.Object

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

Constructor Details

FutureJob

public FutureJob(Callable<RESULT_TYPE> callable)

FutureJob

public FutureJob(Runnable runnable)

Method Details

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<RESULT_TYPE>

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<RESULT_TYPE>

isDone

public boolean isDone()

Specified by:

isDone in interface Future<RESULT_TYPE>

get

public RESULT_TYPE get()
                throws InterruptedException,
ExecutionException

Specified by:

get in interface Future<RESULT_TYPE>

Throws:

InterruptedException

ExecutionException

get

public RESULT_TYPE get(long timeout,
 @NotNull
 @NotNull TimeUnit unit)
                throws InterruptedException,
ExecutionException,
TimeoutException

Specified by:

get in interface Future<RESULT_TYPE>

Throws:

InterruptedException

ExecutionException

TimeoutException

cancelled

public void cancelled()

Description copied from class: Job

This method is called if the job is explicitly cancelled before it becomes ready or times out.

Overrides:

cancelled in class TimedJob

timedOut

public void timedOut()

Description copied from class: Job

This method is invoked if the job times out.

Specified by:

timedOut in class Job