Package gov.nasa.jpl.aerie.scheduler.server.services

Class ThreadedSchedulerAgent

java.lang.Object

gov.nasa.jpl.aerie.scheduler.server.services.ThreadedSchedulerAgent

All Implemented Interfaces:

SchedulerAgent

public final class ThreadedSchedulerAgent
extends Object
implements SchedulerAgent

Method Summary

Modifier and Type	Method	Description
void	schedule(ScheduleRequest request, ResultsProtocol.WriterRole writer, Supplier<Boolean> canceledListener, int sizeCachedEngineStore)	run the scheduling algorithm on the target plan using the associated scheduling goals mutates the target plan when scheduling is complete! any exceptions related to the particulars of a request should be reported as failures to the writer object; only exceptions fatal to the service itself should be propagated out
static ThreadedSchedulerAgent	spawn(String threadName, SchedulerAgent schedulerAgent)
void	terminate()

Methods inherited from class java.lang.Object

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

Method Details

schedule

public void schedule(ScheduleRequest request,
 ResultsProtocol.WriterRole writer,
 Supplier<Boolean> canceledListener,
 int sizeCachedEngineStore)
              throws InterruptedException

Description copied from interface: SchedulerAgent

run the scheduling algorithm on the target plan using the associated scheduling goals mutates the target plan when scheduling is complete! any exceptions related to the particulars of a request should be reported as failures to the writer object; only exceptions fatal to the service itself should be propagated out

Specified by:

schedule in interface SchedulerAgent

Parameters:

request - details of scheduling request, including target plan version

writer - object representing the request for scheduling results, including space to store results

Throws:

InterruptedException

terminate

public void terminate()
               throws InterruptedException

Throws:

InterruptedException

spawn

public static ThreadedSchedulerAgent spawn(String threadName,
 SchedulerAgent schedulerAgent)