private static class MasterProcedureScheduler.FairQueue<T extends Comparable<T>> extends Object
Modifier and Type | Field and Description |
---|---|
private int |
currentQuantum |
private MasterProcedureScheduler.Queue<T> |
currentQueue |
private int |
quantum |
private MasterProcedureScheduler.Queue<T> |
queueHead |
Constructor and Description |
---|
MasterProcedureScheduler.FairQueue() |
MasterProcedureScheduler.FairQueue(int quantum) |
Modifier and Type | Method and Description |
---|---|
void |
add(MasterProcedureScheduler.Queue<T> queue) |
private int |
calculateQuantum(MasterProcedureScheduler.Queue queue) |
private boolean |
nextQueue() |
MasterProcedureScheduler.Queue<T> |
poll() |
void |
remove(MasterProcedureScheduler.Queue<T> queue) |
private void |
setNextQueue(MasterProcedureScheduler.Queue<T> queue) |
private final int quantum
private MasterProcedureScheduler.Queue<T extends Comparable<T>> currentQueue
private MasterProcedureScheduler.Queue<T extends Comparable<T>> queueHead
private int currentQuantum
public MasterProcedureScheduler.FairQueue()
public MasterProcedureScheduler.FairQueue(int quantum)
public void add(MasterProcedureScheduler.Queue<T> queue)
public void remove(MasterProcedureScheduler.Queue<T> queue)
public MasterProcedureScheduler.Queue<T> poll()
private boolean nextQueue()
private void setNextQueue(MasterProcedureScheduler.Queue<T> queue)
private int calculateQuantum(MasterProcedureScheduler.Queue queue)
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.