Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConcurrentQueue ¶
type ConcurrentQueue struct {
// contains filtered or unexported fields
}
ConcurrentQueue implements a thread safe interface for unbounded FIFO queue.
func (*ConcurrentQueue) Front ¶
func (s *ConcurrentQueue) Front() (interface{}, bool)
func (*ConcurrentQueue) Len ¶
func (s *ConcurrentQueue) Len() int
func (*ConcurrentQueue) Pop ¶
func (s *ConcurrentQueue) Pop() (interface{}, bool)
func (*ConcurrentQueue) PopBatch ¶
func (s *ConcurrentQueue) PopBatch(batchSize int) ([]interface{}, bool)
func (*ConcurrentQueue) Push ¶
func (s *ConcurrentQueue) Push(v interface{})
Source Files
Click to show internal directories.
Click to hide internal directories.