asyncq

Documentation

Index

• Variables
• func StartTaskDispatcher(taskWorkerSize int)
• type Task
• type TaskWorker
  • func NewTaskWorker(id int, taskWorkerQueue chan chan Task) TaskWorker
  • func (t *TaskWorker) Start()

Variables

var TaskQueue chan Task

var TaskWorkerQueue chan chan Task

Functions

func StartTaskDispatcher

func StartTaskDispatcher(taskWorkerSize int)

Types

type Task

type Task interface {
	Perform()
}

type TaskWorker

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

func NewTaskWorker

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

func (*TaskWorker) Start

func (t *TaskWorker) Start()