jobqueue

Documentation

Index

• Variables
• func QueueNext()
• func QueuePush(f func())
• func SetConcurrency(num int)
• type Default

Variables

var Defaults = Default{/* contains filtered or unexported fields */}

Functions

func QueueNext

func QueueNext()

QueueNext function is used to send queue an acknowledgement when a task is completed.

func QueuePush

func QueuePush(f func())

QueuePush function is used to push a task to queue

 task := func(num int){
		println(num)
 }

 jobqueue.QueuePush(func(){
		task(7)
		jobqueue.QueueNext()
 })

func SetConcurrency

func SetConcurrency(num int)

SetConcurrency is used to set limit on concuurent execution of task being pushed in the queue.

Types

type Default

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