org.jctools.queues

Interface MessagePassingQueue.Consumer<T>

Enclosing interface:

MessagePassingQueue<T>

public static interface MessagePassingQueue.Consumer<T>

Method Summary

Modifier and Type	Method and Description
void	accept(T e) This method will process an element already removed from the queue.

Method Detail

accept

void accept(T e)

This method will process an element already removed from the queue. This method is expected to never throw an exception.

Users should be aware that underlying queue implementations may upfront claim parts of the queue for batch operations and this will effect the view on the queue from the accept method. In particular size and any poll/peek methods may take the view that the full batch has already happened.

Parameters:

e - not null