MessageDeque

// - Single mesage take

while((e = queue.take)!=null)
{
  process(e)
}


/Multiple Message - Batch processing

while((e = queue.take)!=null)
{
  
  queue.drainTo(elements);
  
  process(e);
  process(elements);
  
  elements.clear();
}