@InterfaceAudience.Private public abstract class AbstractProcedureScheduler extends Object implements ProcedureScheduler
Modifier and Type | Field and Description |
---|---|
private static org.slf4j.Logger |
LOG |
private long |
nullPollCalls |
private long |
pollCalls |
private boolean |
running |
private ReentrantLock |
schedulerLock |
private Condition |
schedWaitCond |
Constructor and Description |
---|
AbstractProcedureScheduler() |
Modifier and Type | Method and Description |
---|---|
void |
addBack(Procedure procedure)
Inserts the specified element at the end of this queue.
|
void |
addBack(Procedure procedure,
boolean notify)
Inserts the specified element at the end of this queue.
|
void |
addFront(Iterator<Procedure> procedureIterator)
Inserts all elements in the iterator at the front of this queue.
|
void |
addFront(Procedure procedure)
Inserts the specified element at the front of this queue.
|
void |
addFront(Procedure procedure,
boolean notify)
Inserts the specified element at the front of this queue.
|
protected abstract Procedure |
dequeue()
Fetch one Procedure from the queue NOTE: this method is called with the sched lock held.
|
protected abstract void |
enqueue(Procedure procedure,
boolean addFront)
Add the procedure to the queue.
|
long |
getNullPollCalls() |
long |
getPollCalls() |
boolean |
hasRunnables()
Returns true if there are procedures available to process, otherwise false.
|
Procedure |
poll()
Fetch one Procedure from the queue
|
Procedure |
poll(long nanos) |
Procedure |
poll(long timeout,
TimeUnit unit)
Fetch one Procedure from the queue
|
protected void |
push(Procedure procedure,
boolean addFront,
boolean notify) |
protected abstract boolean |
queueHasRunnables()
Returns true if there are procedures available to process.
|
protected abstract int |
queueSize()
Returns the number of elements in this queue.
|
protected void |
schedLock() |
protected void |
schedUnlock() |
void |
signalAll()
In case the class is blocking on poll() waiting for items to be added, this method should awake
poll() and poll() should return.
|
int |
size()
Returns the number of elements in this queue.
|
void |
start()
Start the scheduler
|
void |
stop()
Stop the scheduler
|
protected void |
waitProcedure(LockAndQueue lockAndQueue,
Procedure proc) |
(package private) void |
wakeEvents(ProcedureEvent[] events)
Wake up all of the given events.
|
protected void |
wakePollIfNeeded(int waitingCount) |
protected void |
wakeProcedure(Procedure procedure) |
protected int |
wakeWaitingProcedures(LockAndQueue lockAndQueue)
Wakes up given waiting procedures by pushing them back into scheduler queues.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
clear, completionCleanup, getLockResource, getLocks, yield
private static final org.slf4j.Logger LOG
private final ReentrantLock schedulerLock
private final Condition schedWaitCond
private boolean running
private long pollCalls
private long nullPollCalls
public AbstractProcedureScheduler()
public void start()
ProcedureScheduler
start
in interface ProcedureScheduler
public void stop()
ProcedureScheduler
stop
in interface ProcedureScheduler
public void signalAll()
ProcedureScheduler
signalAll
in interface ProcedureScheduler
protected abstract void enqueue(Procedure procedure, boolean addFront)
procedure
- the Procedure to addaddFront
- true if the item should be added to the front of the queuepublic void addFront(Procedure procedure)
ProcedureScheduler
addFront
in interface ProcedureScheduler
procedure
- the Procedure to addpublic void addFront(Procedure procedure, boolean notify)
ProcedureScheduler
addFront
in interface ProcedureScheduler
procedure
- the Procedure to addnotify
- whether need to notify workerpublic void addFront(Iterator<Procedure> procedureIterator)
ProcedureScheduler
addFront
in interface ProcedureScheduler
public void addBack(Procedure procedure)
ProcedureScheduler
addBack
in interface ProcedureScheduler
procedure
- the Procedure to addpublic void addBack(Procedure procedure, boolean notify)
ProcedureScheduler
addBack
in interface ProcedureScheduler
procedure
- the Procedure to addnotify
- whether need to notify workerprotected abstract Procedure dequeue()
public Procedure poll()
ProcedureScheduler
poll
in interface ProcedureScheduler
public Procedure poll(long timeout, TimeUnit unit)
ProcedureScheduler
poll
in interface ProcedureScheduler
timeout
- how long to wait before giving up, in units of unitunit
- a TimeUnit determining how to interpret the timeout parameterprotected abstract int queueSize()
protected abstract boolean queueHasRunnables()
public int size()
ProcedureScheduler
size
in interface ProcedureScheduler
public boolean hasRunnables()
ProcedureScheduler
hasRunnables
in interface ProcedureScheduler
public long getPollCalls()
public long getNullPollCalls()
void wakeEvents(ProcedureEvent[] events)
events
- the list of events to wakeprotected int wakeWaitingProcedures(LockAndQueue lockAndQueue)
waitQueue
.protected void waitProcedure(LockAndQueue lockAndQueue, Procedure proc)
protected void wakeProcedure(Procedure procedure)
protected void schedLock()
protected void schedUnlock()
protected void wakePollIfNeeded(int waitingCount)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.