Package org.processmining.earthmoversstochasticconformancechecking.helperclasses

Class QueueCombination

  • public class QueueCombination
extends java.lang.Object

    • Field Summary

      Fields 
      Modifier and Type Field Description
      protected java.util.concurrent.ConcurrentLinkedQueue<byte[]> globalQueue  
      protected java.util.concurrent.atomic.AtomicInteger globalQueueSize  
      protected java.util.PriorityQueue<byte[]> localQueue  

    • Constructor Summary

      Constructors 
      Constructor Description
      QueueCombination​(java.util.concurrent.ConcurrentLinkedQueue<byte[]> globalQueue, java.util.concurrent.atomic.AtomicInteger globalQueueSize)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void add​(byte[] prefixProbabilityMarking)  
      byte[] poll()  

      • Methods inherited from class java.lang.Object

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

    • Field Detail

      • globalQueue

        protected final java.util.concurrent.ConcurrentLinkedQueue<byte[]> globalQueue

      • globalQueueSize

        protected final java.util.concurrent.atomic.AtomicInteger globalQueueSize

      • localQueue

        protected final java.util.PriorityQueue<byte[]> localQueue

    • Constructor Detail

      • QueueCombination

        public QueueCombination​(java.util.concurrent.ConcurrentLinkedQueue<byte[]> globalQueue,
                        java.util.concurrent.atomic.AtomicInteger globalQueueSize)

    • Method Detail

      • add

        public void add​(byte[] prefixProbabilityMarking)

      • poll

        public byte[] poll()