job

package

v0.0.0-...-abc415f Latest Latest Go to latest Published: Jan 22, 2018 License: MIT Imports: 3 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var JobQueue chan Job

JobQueue A buffered channel that we can send work requests on.

This section is empty.

type Dispatcher struct {
	// A pool of workers channels that are registered with the dispatcher
	MaxWorkers int
	WorkerPool chan chan Job
}

Dispatcher 工作池

func NewDispatcher(maxWorkers int) *Dispatcher

NewDispatcher 创建新的工作池

func (d *Dispatcher) Run()

Run Dispatcher.Run 工作池开始工作

type Job struct {
	Task Task
}

Job represents the job to be run

type Task interface {
	RunTask()
}

Task 任务接口

type TaskDemo struct {
	OpenID string
	Text   string
}

TaskDemo struct

func (p *TaskDemo) RunTask()

RunTask 实现 Task.RunTask()

type TaskSpider struct {
	URL string
}

TaskSpider struct 采集任务

func (t *TaskSpider) RunTask()

RunTask 实现 Task.RunTask()

type Worker struct {
	WorkerPool chan chan Job
	JobChannel chan Job
	// contains filtered or unexported fields
}

Worker represents the worker that executes the job

func NewWorker(workerPool chan chan Job) Worker

NewWorker new worker

func (w Worker) Start()

Start method starts the run loop for the worker, listening for a quit channel in case we need to stop it

func (w Worker) Stop()

Stop signals the worker to stop listening for work requests.