com.xilinx.rapidwright.util

Class JobQueue

Object

com.xilinx.rapidwright.util.JobQueue

public class JobQueue
extends Object

Used to manage a batch of task jobs to run in parallel. Created on: Jan 26, 2018

Field Summary

Fields

Modifier and Type	Field and Description
static String	LSF_AVAILABLE_OPTION
static String	LSF_QUEUE_OPTION
static String	LSF_RESOURCE_OPTION
static int	MAX_LOCAL_CONCURRENT_JOBS
static int	MAX_LSF_CONCURRENT_JOBS
static boolean	USE_LSF_IF_AVAILABLE

Constructor Summary

Constructors

Constructor and Description
JobQueue()
JobQueue(boolean printJobStart)

Method Summary

Modifier and Type	Method and Description
boolean	addJob(Job j)
boolean	addRunningJob(Job j)
static Job	createJob() Create a new Job.
int	getCount()
static boolean	isLSFAvailable()
boolean	killAllRunningJobs()
static void	main(String[] args)
boolean	runAllToCompletion()
boolean	runAllToCompletion(int maxNumRunningJobs)

Methods inherited from class Object

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

Field Detail

MAX_LOCAL_CONCURRENT_JOBS

public static int MAX_LOCAL_CONCURRENT_JOBS

MAX_LSF_CONCURRENT_JOBS

public static int MAX_LSF_CONCURRENT_JOBS

USE_LSF_IF_AVAILABLE

public static boolean USE_LSF_IF_AVAILABLE

LSF_AVAILABLE_OPTION

public static final String LSF_AVAILABLE_OPTION

See Also:

Constant Field Values

LSF_RESOURCE_OPTION

public static final String LSF_RESOURCE_OPTION

See Also:

Constant Field Values

LSF_QUEUE_OPTION

public static final String LSF_QUEUE_OPTION

See Also:

Constant Field Values

Constructor Detail

JobQueue

public JobQueue(boolean printJobStart)

JobQueue

public JobQueue()

Method Detail

addJob

public boolean addJob(Job j)

addRunningJob

public boolean addRunningJob(Job j)

runAllToCompletion

public boolean runAllToCompletion()

runAllToCompletion

public boolean runAllToCompletion(int maxNumRunningJobs)

killAllRunningJobs

public boolean killAllRunningJobs()

isLSFAvailable

public static boolean isLSFAvailable()

createJob

public static Job createJob()

Create a new Job. Will use LSF if available. If not, a local job will be created.

Returns:

the new Job

main

public static void main(String[] args)
                 throws InterruptedException

Throws:

InterruptedException

getCount

public int getCount()