org.mini2Dx.miniscript.core.util

Class ScheduledTaskQueue

java.lang.Object

org.mini2Dx.miniscript.core.util.AbstractConcurrentQueue<E>

org.mini2Dx.miniscript.core.util.AbstractConcurrentBlockingQueue<E>

org.mini2Dx.miniscript.core.util.ReadWritePriorityQueue<ScheduledTask>

org.mini2Dx.miniscript.core.util.ScheduledTaskQueue

All Implemented Interfaces:

java.lang.Iterable<ScheduledTask>, java.util.Collection<ScheduledTask>, java.util.concurrent.BlockingQueue<ScheduledTask>, java.util.Queue<ScheduledTask>

public class ScheduledTaskQueue
extends ReadWritePriorityQueue<ScheduledTask>

Field Summary

Fields inherited from class org.mini2Dx.miniscript.core.util.AbstractConcurrentBlockingQueue

waitingForItemsMonitor, waitingForRemovalMonitor

Fields inherited from class org.mini2Dx.miniscript.core.util.AbstractConcurrentQueue

internalQueue, lock

Constructor Summary

Constructors

Constructor and Description
ScheduledTaskQueue()
ScheduledTaskQueue(int maxCapacity)

Method Summary

Modifier and Type	Method and Description
ScheduledTask	take()

Methods inherited from class org.mini2Dx.miniscript.core.util.AbstractConcurrentBlockingQueue

add, addAll, drainTo, drainTo, offer, offer, poll, poll, put, remainingCapacity, remove, removeAll

Methods inherited from class org.mini2Dx.miniscript.core.util.AbstractConcurrentQueue

clear, contains, containsAll, element, isEmpty, iterator, lazyOffer, peek, remove, retainAll, size, toArray, toArray

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.BlockingQueue

contains

Methods inherited from interface java.util.Queue

element, peek, remove

Methods inherited from interface java.util.Collection

clear, containsAll, equals, hashCode, isEmpty, iterator, parallelStream, removeIf, retainAll, size, spliterator, stream, toArray, toArray

Methods inherited from interface java.lang.Iterable

forEach

Constructor Detail

ScheduledTaskQueue

public ScheduledTaskQueue()

ScheduledTaskQueue

public ScheduledTaskQueue(int maxCapacity)

Method Detail

take

public ScheduledTask take()
                   throws java.lang.InterruptedException

Specified by:

take in interface java.util.concurrent.BlockingQueue<ScheduledTask>

Overrides:

take in class AbstractConcurrentBlockingQueue<ScheduledTask>

Throws:

java.lang.InterruptedException