Package gov.nasa.jpl.aerie.merlin.framework

Class ThreadedTask<Return>

java.lang.Object

gov.nasa.jpl.aerie.merlin.framework.ThreadedTask<Return>

All Implemented Interfaces:

gov.nasa.jpl.aerie.merlin.protocol.model.Task<Return>

public final class ThreadedTask<Return>
extends Object
implements gov.nasa.jpl.aerie.merlin.protocol.model.Task<Return>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	ThreadedTask.TaskFailureException

Field Summary

Fields

Modifier and Type	Field	Description
static boolean	CACHE_READS

Constructor Summary

Constructors

Constructor	Description
ThreadedTask(Executor executor, Scoped<Context> rootContext, Supplier<Return> task)

Method Summary

Modifier and Type	Method	Description
gov.nasa.jpl.aerie.merlin.protocol.model.Task<Return>	duplicate(Executor executor)
void	release()
gov.nasa.jpl.aerie.merlin.protocol.types.TaskStatus<Return>	step(gov.nasa.jpl.aerie.merlin.protocol.driver.Scheduler scheduler)

Methods inherited from class java.lang.Object

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

Methods inherited from interface gov.nasa.jpl.aerie.merlin.protocol.model.Task

andThen, dropOutput

Field Details

CACHE_READS

public static boolean CACHE_READS

Constructor Details

ThreadedTask

public ThreadedTask(Executor executor,
 Scoped<Context> rootContext,
 Supplier<Return> task)

Method Details

step

public gov.nasa.jpl.aerie.merlin.protocol.types.TaskStatus<Return> step(gov.nasa.jpl.aerie.merlin.protocol.driver.Scheduler scheduler)

Specified by:

step in interface gov.nasa.jpl.aerie.merlin.protocol.model.Task<Return>

release

public void release()

Specified by:

release in interface gov.nasa.jpl.aerie.merlin.protocol.model.Task<Return>

duplicate

public gov.nasa.jpl.aerie.merlin.protocol.model.Task<Return> duplicate(Executor executor)

Specified by:

duplicate in interface gov.nasa.jpl.aerie.merlin.protocol.model.Task<Return>