internal

Documentation

Index

• func SpinLock() sync.Locker
• type AsyncJobQueue
  • func NewAsyncJobQueue() AsyncJobQueue
  • func (q *AsyncJobQueue) ForEach() (err error)
  • func (q *AsyncJobQueue) Push(job Job)
• type Job

Functions

func SpinLock

func SpinLock() sync.Locker

SpinLock creates a new spin-lock.

Types

type AsyncJobQueue

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

AsyncJobQueue queues pending tasks.

func NewAsyncJobQueue

func NewAsyncJobQueue() AsyncJobQueue

NewAsyncJobQueue creates a note-queue.

func (*AsyncJobQueue) ForEach

func (q *AsyncJobQueue) ForEach() (err error)

ForEach iterates this queue and executes each note with a given func.

func (*AsyncJobQueue) Push

func (q *AsyncJobQueue) Push(job Job)

Push pushes a item into queue.

type Job

type Job func() error

Job is a asynchronous function.