Package at.letto.queue

package at.letto.queue
  • Class
    Description
    TaskQueue<T,K>
    Generische, threadsichere Task-Queue mit: - insertTop(item): Einfügen am Kopf → als nächstes verarbeitet - insertEnd(item): Einfügen am Ende → FIFO - insAtTime(item,m): geplanter Start frühestens in m Minuten Verzögerte Items (insAtTime) werden in eine DelayQueue gelegt und bei Fälligkeit in die Ready-Deque verschoben.
    TaskQueue.Builder<T,K>
     
    TaskQueue.DelayedItem<T,K>
    Wrapper für DelayQueue – vergleicht nach Fälligkeit; Gleichheit über Schlüssel.
    TaskQueue.Entry
     
    TaskQueue.ErrorHandler<T>
    Optionaler Fehler-Callback.
    TaskQueue.TaskProcessor<T>
    Verarbeitet ein Item.