async

Documentation

Overview

tools/async/pool.go

Index

• type Task
• type Worker
• type WorkerMetrics
• type WorkerPool

Types

type Task

type Task interface {
	Execute(context.Context) (interface{}, error)
	ID() string
	Priority() int
}

Task 任务接口

type Worker

type Worker struct {
	// contains filtered or unexported fields
}

Worker 工作者

type WorkerMetrics

type WorkerMetrics struct {
	TasksProcessed uint64
	ErrorCount     uint64
	ProcessingTime time.Duration
	IdleTime       time.Duration
}

WorkerMetrics 工作者指标

type WorkerPool

type WorkerPool struct {
	// contains filtered or unexported fields
}

WorkerPool 工作池