E
- public interface TransactionalQueue<E> extends TransactionalObject, BaseQueue<E>
BaseQueue
.Modifier and Type | Method and Description |
---|---|
boolean |
offer(E e)
Inserts the specified element into this queue if it is possible to do
so immediately without violating capacity restrictions.
|
boolean |
offer(E e,
long timeout,
TimeUnit unit)
Inserts the specified element into this queue, waiting up to the
specified wait time if necessary for space to become available.
|
E |
peek() |
E |
peek(long timeout,
TimeUnit unit) |
E |
poll()
Retrieves and removes the head of this queue,
or returns null if this queue is empty.
|
E |
poll(long timeout,
TimeUnit unit)
Retrieves and removes the head of this queue, waiting up to the
specified wait time if necessary for an element to become available.
|
int |
size()
Returns the number of elements in this collection.
|
E |
take()
Retrieves and removes the head of this queue, waiting if necessary
until an element becomes available.
|
destroy, getName, getPartitionKey, getServiceName
boolean offer(E e)
boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException
offer
in interface BaseQueue<E>
e
- the element to addtimeout
- how long to wait before giving up, in units of
unitunit
- a TimeUnit determines how to interpret the
timeout parameterInterruptedException
- if interrupted while waitingE take() throws InterruptedException
take
in interface BaseQueue<E>
InterruptedException
- if interrupted while waitingE poll()
E poll(long timeout, TimeUnit unit) throws InterruptedException
poll
in interface BaseQueue<E>
timeout
- how long to wait before giving up, in units of
unitunit
- a TimeUnit determining how to interpret the
timeout parameterInterruptedException
- if interrupted while waitingE peek()
E peek(long timeout, TimeUnit unit) throws InterruptedException
InterruptedException
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.