core

package

v0.0.7 Latest Latest Go to latest Published: Dec 11, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewBlocking[T any](params *param.Queue) (blocking *Blocking[T])

func (b *Blocking[T]) Dequeue() (item T)

func (b *Blocking[T]) Empty() bool

func (b *Blocking[T]) Enqueue(required T, optionals ...T)

func (b *Blocking[T]) Size() int

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

func NewDefault[T any](params *param.Queue) *Default[T]

func (d *Default[T]) Dequeue() (item T)

func (d *Default[T]) Empty() bool

func (d *Default[T]) Enqueue(required T, optionals ...T)

func (d *Default[T]) Size() int

Path	Synopsis
internal
priority