asyncq

package

v0.0.0-...-d41341d Latest Latest Go to latest Published: Jun 9, 2018 License: BSD-3-Clause Imports: 1 Imported by: 0

Details

This section is empty.

View Source

var TaskQueue chan Task

View Source

var TaskWorkerQueue chan chan Task

func StartTaskDispatcher(taskWorkerSize int)

type Task interface {
	Perform()
}

type TaskWorker struct {
	ID              int
	TaskChannel     chan Task
	TaskWorkerQueue chan chan Task
}

func NewTaskWorker(id int, taskWorkerQueue chan chan Task) TaskWorker

func (t *TaskWorker) Start()