本文整理了Java中org.renci.jlrm.Queue类的一些代码示例，展示了Queue类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Queue类的具体详情如下：
包路径：org.renci.jlrm.Queue
类名称：Queue

Queue介绍

暂无

代码示例

代码示例来源：origin: org.renci.jlrm.jlrm-slurm/jlrm-slurm-ssh

job.setTransferExecutable(Boolean.TRUE);
job.setTransferInputs(Boolean.TRUE);
job.setQueueName(this.queue.getName());
job.setName(this.jobName);
job.setHostCount(1);
job.setNumberOfProcessors(getQueue().getNumberOfProcessors());
job.setOutput(new File("glidein.out"));
job.setError(new File("glidein.err"));
job.setWallTime(this.queue.getRunTime());
job.setMemory(null);
long maxRunTimeAdjusted = this.queue.getRunTime() - 20;
if (maxRunTimeAdjusted < 0) {
  maxRunTimeAdjusted = this.queue.getRunTime() / 2;

代码示例来源：origin: org.renci.gate/gate-api

if (queue.getName().equals(glideinMetric.getQueueName())) {
  if (StringUtils.isNotEmpty(activeQueues) && !activeQueues.contains(queue.getName())) {
    logger.info("excluding \"{}\" queue due to not being active", queue.getName());
    siteQueueScoreIter.remove();
    continue;
  if (glideinMetric.getPending() >= queue.getMaxPending()) {
    logger.info("Pending job threshold has been met: {} of {}", glideinMetric.getPending(),
        queue.getMaxPending());
    siteQueueScoreIter.remove();
    continue;
  if (glideinMetric.getRunning() >= queue.getMaxRunning()) {
    logger.info("totalJobs is greater that queue max job limit");
    siteQueueScoreIter.remove();

代码示例来源：origin: org.renci.gate/gate-api

&& queue.getName().equals(glideinMetric.getQueueName())) {

代码示例来源：origin: org.renci.gate/gate-api

score *= queue.getWeight();
logger.info("adjusted by queue weight = {}", score);
if (localCondorMetrics.getSiteRequiredJobOccurance() > 0) {

代码示例来源：origin: org.renci.gate/gate-api

&& queue.getName().equals(glideinMetric.getQueueName())) {

代码示例来源：origin: org.renci.gate/gate-api

score *= queue.getWeight();
logger.info("adjusted by queue weight = {}", score);
if (localCondorMetrics.getSiteRequiredJobOccurance() > 0) {

代码示例来源：origin: org.renci.jlrm.jlrm-lsf/jlrm-lsf-ssh

job.setTransferExecutable(Boolean.TRUE);
job.setTransferInputs(Boolean.TRUE);
job.setQueueName(this.queue.getName());
job.setName(this.jobName);
job.setHostCount(1);
job.setNumberOfProcessors(getQueue().getNumberOfProcessors());
job.setOutput(new File("glidein.out"));
job.setError(new File("glidein.err"));
job.setWallTime(queue.getRunTime());
job.setMemory(null);
long maxRunTimeAdjusted = queue.getRunTime() - 20;
if (maxRunTimeAdjusted < 0) {
  maxRunTimeAdjusted = queue.getRunTime() / 2;

代码示例来源：origin: org.renci.gate/gate-api

&& queue.getName().equals(glideinMetric.getQueueName())) {

代码示例来源：origin: org.renci.gate/gate-api

score *= queue.getWeight();
logger.info("adjusted by queue weight = {}", score);
if (localCondorMetrics.getSiteRequiredJobOccurance() > 0) {

代码示例来源：origin: org.renci.jlrm.jlrm-pbs/jlrm-pbs-ssh

job.setTransferExecutable(Boolean.TRUE);
job.setTransferInputs(Boolean.TRUE);
job.setQueueName(this.queue.getName());
job.setName(this.jobName);
job.setHostCount(1);
job.setNumberOfProcessors(getQueue().getNumberOfProcessors());
job.setOutput(new File("glidein.out"));
job.setError(new File("glidein.err"));
job.setWallTime(this.queue.getRunTime());
job.setMemory(null);
long maxRunTimeAdjusted = this.queue.getRunTime() - 20;
if (maxRunTimeAdjusted < 0) {
  maxRunTimeAdjusted = this.queue.getRunTime() / 2;

代码示例来源：origin: org.renci.jlrm.jlrm-sge/jlrm-sge-ssh

job.setTransferExecutable(Boolean.TRUE);
job.setTransferInputs(Boolean.TRUE);
job.setQueueName(this.queue.getName());
job.setName(this.jobName);
job.setHostCount(1);
job.setNumberOfProcessors(getQueue().getNumberOfProcessors());
job.setOutput(new File("glidein.out"));
job.setError(new File("glidein.err"));
job.setWallTime(this.queue.getRunTime());
job.setMemory(null);
long maxRunTimeAdjusted = this.queue.getRunTime() - 20;
if (maxRunTimeAdjusted < 0) {
  maxRunTimeAdjusted = this.queue.getRunTime() / 2;