Package org.mpi_sws.jmc.api.util.concurrent

Class JmcFuture<T>

java.lang.Object

org.mpi_sws.jmc.api.util.concurrent.JmcFuture<T>

Type Parameters:

T - The return type of the callable function.

All Implemented Interfaces:

Runnable, Future<T>, RunnableFuture<T>

public class JmcFuture<T>
extends Object
implements RunnableFuture<T>

A future that runs a callable function in a new thread.

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.concurrent.Future

Future.State

Constructor Summary

Constructors

Constructor	Description
JmcFuture(Runnable runnable, Long taskId)
JmcFuture(Runnable runnable, T result, Long taskId)
JmcFuture(Callable<T> function, Long taskId)
JmcFuture(JmcThread thread)
JmcFuture(JmcThread thread, T result)

Method Summary

Modifier and Type	Method	Description
boolean	cancel(boolean b)	Cancel the future.
T	get()
T	get(long l, TimeUnit timeUnit)
Long	getTaskId()
boolean	isCancelled()
boolean	isDone()
void	run()	Run the underlying callable function in a new thread.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.Future

exceptionNow, resultNow, state

Constructor Details

JmcFuture

public JmcFuture(Callable<T> function,
 Long taskId)

JmcFuture

public JmcFuture(Runnable runnable,
 Long taskId)

JmcFuture

public JmcFuture(Runnable runnable,
 T result,
 Long taskId)

JmcFuture

public JmcFuture(JmcThread thread,
 T result)

JmcFuture

public JmcFuture(JmcThread thread)

Method Details

getTaskId

public Long getTaskId()

cancel

public boolean cancel(boolean b)

Cancel the future.

Currently unsupported by Jmc. Cannot stop tasks yet.

Specified by:

cancel in interface Future<T>

Parameters:

b - Whether to interrupt the future.

Returns:

Whether the future was successfully cancelled.

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<T>

isDone

public boolean isDone()

Specified by:

isDone in interface Future<T>

get

public T get()
      throws InterruptedException,
ExecutionException

Specified by:

get in interface Future<T>

Throws:

InterruptedException

ExecutionException

get

public T get(long l,
 TimeUnit timeUnit)
      throws InterruptedException,
ExecutionException,
TimeoutException

Specified by:

get in interface Future<T>

Throws:

InterruptedException

ExecutionException

TimeoutException

run

public void run()

Run the underlying callable function in a new thread.

Specified by:

run in interface Runnable

Specified by:

run in interface RunnableFuture<T>