Class BlockingQueue
class BlockingQueue(T);
Constructors
| Name | Description |
|---|---|
this
()
|
Fields
| Name | Type | Description |
|---|---|---|
_buffer
|
T[] | |
_closed
|
bool | |
_condition
|
Condition | |
_mutex
|
Mutex | |
_readPos
|
int | |
_writePos
|
int |
Properties
| Name | Type | Description |
|---|---|---|
closed[get]
|
bool | returns true if queue is closed |
Methods
| Name | Description |
|---|---|
append
(item)
|
|
close
()
|
|
get
(value, timeoutMillis)
|
|
getAll
(values, timeoutMillis)
|
|
move
()
|
|
put
(item)
|
|
put
(items)
|