queue

package

v0.3.7 Latest Latest Go to latest Published: Aug 2, 2026 License: MIT Imports: 2 Imported by: 0

Details

Package queue provides asynchronous task execution interfaces and implementations.

This section is empty.

View Source

var ErrQueueFull = errors.New("queue is full")

ErrQueueFull is returned when the queue cannot accept more tasks.

This section is empty.

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

AntsQueue is an in-memory queue implementation using ants pool.

func NewAntsQueue(size int) (*AntsQueue, error)

NewAntsQueue creates a new AntsQueue with the given pool size.

func (q *AntsQueue) Close()

Close releases the pool resources.

func (q *AntsQueue) Submit(task func()) error

Submit adds a task to the queue. Returns ErrQueueFull if the queue is full.

type Queue interface {
	Submit(task func()) error
	Close()
}

Queue defines the interface for asynchronous task execution.