queue

Documentation

Overview

Package queue provides a sequential, non-blocking, unbounded task execution queue. It mimics Node.js's event loop and is deeply inspired by Kubernetes workqueue.

Index

• type Queue
  • func New() *Queue
  • func (q *Queue) Close()
  • func (q *Queue) Enqueue(task func())
  • func (q *Queue) IsShuttingDown() bool
  • func (q *Queue) Size() int
  • func (q *Queue) TryClose()

Types

type Queue

type Queue struct {
	// contains filtered or unexported fields
}

Queue serializes function execution through a single goroutine. It uses an unbounded slice backed by a condition variable to ensure Enqueue never blocks the caller.

func New

func New() *Queue

New creates a new Queue and starts the internal consumer goroutine.

func (*Queue) Close

func (q *Queue) Close()

Close shuts down the Queue gracefully. It waits for all previously enqueued tasks to complete before returning.

func (*Queue) Enqueue

func (q *Queue) Enqueue(task func())

Enqueue adds a task to the queue for sequential execution. It returns immediately and NEVER blocks.

func (*Queue) IsShuttingDown

func (q *Queue) IsShuttingDown() bool

IsShuttingDown reports whether TryClose or Close has been called.

func (*Queue) Size

func (q *Queue) Size() int

Size returns the number of pending tasks in the queue.

func (*Queue) TryClose

func (q *Queue) TryClose()

TryClose shuts down the Queue without waiting for completion. Pending tasks are discarded.