_2_block_queue

Documentation

Index

• type BlockingQueue
  • func NewBlockingQueue[T any](ctx context.Context, queueSize int) *BlockingQueue[T]
  • func (q *BlockingQueue[T]) Poll() T
  • func (q *BlockingQueue[T]) Push(value T)
  • func (q *BlockingQueue[T]) SetRejectHandler(handler RejectHandler)
  • func (q *BlockingQueue[T]) TryPoll(timeout time.Duration) (ret T, ok bool)
  • func (q *BlockingQueue[T]) TryPush(value T, timeout time.Duration) bool
• type Queue
• type RejectHandler

Types

type BlockingQueue

type BlockingQueue[T any] struct {
	// contains filtered or unexported fields
}

func NewBlockingQueue

func NewBlockingQueue[T any](ctx context.Context, queueSize int) *BlockingQueue[T]

func (*BlockingQueue[T]) Poll

func (q *BlockingQueue[T]) Poll() T

func (*BlockingQueue[T]) Push

func (q *BlockingQueue[T]) Push(value T)

func (*BlockingQueue[T]) SetRejectHandler

func (q *BlockingQueue[T]) SetRejectHandler(handler RejectHandler)

SetRejectHandler Set a reject handler.

func (*BlockingQueue[T]) TryPoll

func (q *BlockingQueue[T]) TryPoll(timeout time.Duration) (ret T, ok bool)

func (*BlockingQueue[T]) TryPush

func (q *BlockingQueue[T]) TryPush(value T, timeout time.Duration) bool

type Queue

type Queue[T any] interface {
	Push(value T)
	TryPush(value T, timeout time.Duration) bool
	Poll() T
	TryPoll(timeout time.Duration) (T, bool)
}

type RejectHandler

type RejectHandler func(ctx context.Context) bool

RejectHandler Reject push into queue if return false.