Scheduler (Fiji Javadocs 0-SNAPSHOT API)

java.lang.Object
- java.lang.Thread
- - edu.utexas.clm.archipelago.compute.Scheduler

All Implemented Interfaces:: ProcessListener, Runnable

public class Scheduler
extends Thread
implements ProcessListener

Nested Class Summary
- Nested classes/interfaces inherited from class java.lang.Thread
  Thread.State, Thread.UncaughtExceptionHandler

Field Summary
- Fields inherited from class java.lang.Thread
  MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors
Constructor and Description

Scheduler(Cluster cluster)

Constructors
Constructor and Description
`Scheduler(Cluster cluster)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`boolean`	`cancelJob(long id, boolean force)` Attempts to cancel a running job with the given id, optionally cancelling jobs that have already been submitted to a node.
`void`	`close()`
`void`	`error(long id, Throwable t)`
`ClusterNode`	`getNode(ProcessManager pm)`
`ArrayList<ProcessManager<?>>`	`getRemainingJobs()`
`int`	`numQueuedJobs()`
`int`	`numRunningJobs()`
`void`	`poke()`
`boolean`	`processFinished(ProcessManager<?> process)` This method will be called when a ProcessManager is returned from the cluster.
`<T> ArchipelagoFuture<T>`	`queueNormal(Callable<T> callable, float np, boolean f)`
`<T> ArchipelagoFuture<T>`	`queuePriority(Callable<T> callable, float np, boolean f)`
`boolean`	`reschedule(ProcessManager pm)`
`void`	`run()`
`void`	`start()`

Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Constructor Detail
  - Scheduler
```
public Scheduler(Cluster cluster)
```
- Method Detail
  - processFinished
```
public boolean processFinished(ProcessManager<?> process)
```
    Description copied from interface: ProcessListener
    
    This method will be called when a ProcessManager is returned from the cluster.
    
    Specified by:
    
    processFinished in interface ProcessListener
    
    Parameters:
    
    process - a ProcessManager that just returned from the cluster
    
    Returns:
    
    true or not. This method may be a void return in the future.
  - error
```
public void error(long id,
                  Throwable t)
```
  - numRunningJobs
```
public int numRunningJobs()
```
  - numQueuedJobs
```
public int numQueuedJobs()
```
  - queueNormal
```
public <T> ArchipelagoFuture<T> queueNormal(Callable<T> callable,
                                            float np,
                                            boolean f)
```
  - queuePriority
```
public <T> ArchipelagoFuture<T> queuePriority(Callable<T> callable,
                                              float np,
                                              boolean f)
```
  - reschedule
```
public boolean reschedule(ProcessManager pm)
```
  - getNode
```
public ClusterNode getNode(ProcessManager pm)
```
  - cancelJob
```
public boolean cancelJob(long id,
                         boolean force)
```
    Attempts to cancel a running job with the given id, optionally cancelling jobs that have already been submitted to a node.
    
    Parameters:
    
    id - the id of the job to cancel
    
    force - set true to cancel a job that is currently executing, false otherwise.
    
    Returns:
    
    true if the job was cancelled, false if not. If false, either the job has already finished, or it is already executing and force is set false.
  - run
```
public void run()
```
    Specified by:
    
    run in interface Runnable
    
    Overrides:
    
    run in class Thread
  - start
```
public void start()
```
    Overrides:
    
    start in class Thread
  - close
```
public void close()
```
  - poke
```
public void poke()
```
  - getRemainingJobs
```
public ArrayList<ProcessManager<?>> getRemainingJobs()
```

Class Scheduler

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Field Summary

Fields inherited from class java.lang.Thread

Constructor Summary

Method Summary

Methods inherited from class java.lang.Thread

Methods inherited from class java.lang.Object

Constructor Detail

Scheduler

Method Detail

processFinished

error

numRunningJobs

numQueuedJobs

queueNormal

queuePriority

reschedule

getNode

cancelJob

run

start

close

poke

getRemainingJobs