Constructor and Description |
---|
BlockingQueueNioQueue(BlockingQueue<WriteRequest> delegate,
int writeEnqueuingTimeoutInMs) |
Modifier and Type | Method and Description |
---|---|
boolean |
isEmpty()
Returns
true if the queue contains no element. |
boolean |
offer(WriteRequest writeRequest)
Enqueue a frame, block if the queue is full.
|
WriteRequest |
poll()
Retrieves and removes the head of this queue,
or returns
null if this queue is empty. |
int |
size()
Get the current size of the queue.
|
public BlockingQueueNioQueue(BlockingQueue<WriteRequest> delegate, int writeEnqueuingTimeoutInMs)
public boolean offer(WriteRequest writeRequest) throws InterruptedException
NioQueue
offer
in interface NioQueue
InterruptedException
public int size()
NioQueue
public WriteRequest poll()
NioQueue
null
if this queue is empty.Copyright © 2022 VMware, Inc. or its affiliates.. All rights reserved.