public interface QueuesManager extends AutoCloseable
Modifier and Type | Method and Description |
---|---|
int |
count()
Returns the number of queues.
|
boolean |
isEmpty(int queue)
Returns true if there is no element in the queue.
|
SourceNode |
poll(int queue)
Get a node from a queue.
|
SourceNode |
poll(int queue,
long timeout,
TimeUnit unit)
Get a node from a queue, with a timeout.
|
void |
put(int queue,
SourceNode node)
Put a node into a queue.
|
int |
size(int queue)
Returns the number of elements in the queue.
|
close
int count()
void put(int queue, SourceNode node) throws InterruptedException
InterruptedException
SourceNode poll(int queue)
SourceNode poll(int queue, long timeout, TimeUnit unit) throws InterruptedException
InterruptedException
boolean isEmpty(int queue)
int size(int queue)
Copyright © 2017 Nuxeo. All rights reserved.