asyncq

package
Version: v0.0.0-...-d41341d Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 9, 2018 License: BSD-3-Clause Imports: 1 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source
var TaskQueue chan Task
View Source
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()

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL