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.