package
0.0.0-20230803183215-8bd077957dc1
Repository: https://github.com/weedge/pkg.git
Documentation: pkg.go.dev

# Functions

ExecuteInParallel will (in parallel) call the provided function with each item in the queue until the queue is exhausted.
New is a constructor for a new threadsafe queue.
NewRingBuffer will allocate, initialize, and return a ring buffer with the specified size.
NewRunner returns a task runner.

# Constants

CacheLinePadSize represents the CPU Cache Line Padding Size, compliant with the current running CPU Architect.
Cancelled job is cancelled.
Cancelling job is cancelling.
Failed job is failed when execute.
Finished job is complete.
Pending job is wait to running.
Running job is running.

# Variables

ErrDisposed is returned when an operation is performed on a disposed queue.
ErrEmptyQueue is returned when an non-applicable queue operation was called due to the queue's empty item state.
ErrJobCancelled error job cancelled.
ErrTimeout is returned when an applicable queue operation times out.
No description provided by the author

# Structs

Job is do for something with state.
Queue is the struct responsible for tracking the state of the queue.
RingBuffer is a MPMC buffer that achieves threadsafety with CAS operations only.
Runner TODO.

# Type aliases

JobState is the job state.