queue

README

Goroutine concurrency queue process

Example

  import "github.com/muhfajar/queue"
  ...
  ALLOC := 6
  q := NewQueue(&Worker{
  	Thread: 3,
  	Alloc:  ALLOC,
  	Set: Callback{
  		TaskDone: func(result interface{}) {
  			rs := result.(string)
  			fmt.Println(rs)
  		},
  		QueueDone: func() {
  			fmt.Println("done")
  		},
  	},
  })

  strings := []string{"hello", "world", "fajar", "muhfajar", "queue", "github"}
  for i, s := range strings {
  	index, value := i, s
  	task := func() interface{} {
  		time.Sleep(time.Duration(1) * time.Second)
  		return fmt.Sprintf("pid: %d :: %s", index, value)
  	} 

  	q.Append(task)
  }
 
  q.Start()

Documentation

Index

• Constants
• type Callback
• type Worker
  • func NewQueue(w *Worker) *Worker
  • func (w *Worker) Append(task func() interface{})
  • func (w *Worker) Start()

Constants

const (
	DefaultMaxThread = 25
	DefaultMaxAlloc  = 1000
)

Types

type Callback

type Callback struct {
	TaskDone  func(...interface{})
	QueueDone func()
}

type Worker

type Worker struct {
	Thread int
	Alloc  int
	Set    Callback
	// contains filtered or unexported fields
}

func NewQueue

func NewQueue(w *Worker) *Worker

func (*Worker) Append

func (w *Worker) Append(task func() interface{})

func (*Worker) Start

func (w *Worker) Start()