Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DeleteFunc ¶
func DeleteFunc[T any](q *BlockingQueue[T], f func(t T) bool)
Types ¶
type BlockingQueue ¶
type BlockingQueue[T any] struct { // contains filtered or unexported fields }
func NewBlockingQueue ¶
func NewBlockingQueue[T any](capacity int) *BlockingQueue[T]
func (*BlockingQueue[T]) Dequeue ¶
func (q *BlockingQueue[T]) Dequeue(ctx context.Context) (item T, ok bool)
func (*BlockingQueue[T]) Enqueue ¶
func (q *BlockingQueue[T]) Enqueue(ctx context.Context, item T) bool
func (*BlockingQueue[T]) TryDequeue ¶
func (q *BlockingQueue[T]) TryDequeue() (T, bool)
func (*BlockingQueue[T]) TryEnqueue ¶
func (q *BlockingQueue[T]) TryEnqueue(item T) bool
Source Files
Click to show internal directories.
Click to hide internal directories.