routine

Documentation

Index

• Variables
• func AddTask(taskFunc TaskFunc) error
• func CloseDefaultTask() error
• func CountInfo() (map[string]int, error)
• func SetUpDefaultTask(conf settings.Routine) func() error
• type Task
  • func SetUp(conf settings.Routine) (*Task, error)
  • func (task *Task) AsyncDO(taskFunc TaskFunc) error
  • func (task *Task) Close()
  • func (task Task) CountInfo() map[string]int
  • func (task *Task) RawGoroutineCount() int64
  • func (task *Task) Reboot()
• type TaskFunc

Variables

var (
	NoEnableRoutinePool = errors.New("not enable routine pool, please add enableRtePool field to settings")
	EmptyTaskFunc       = errors.New("task func is nil")
)

Functions

func AddTask

func AddTask(taskFunc TaskFunc) error

AddTask 添加任务

func CloseDefaultTask

func CloseDefaultTask() error

func CountInfo

func CountInfo() (map[string]int, error)

CountInfo 获取协程池个数信息

func SetUpDefaultTask

func SetUpDefaultTask(conf settings.Routine) func() error

SetUpDefaultTask 初始化后台任务

Types

type Task

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

func SetUp

func SetUp(conf settings.Routine) (*Task, error)

SetUp 初始化协程池

func (*Task) AsyncDO

func (task *Task) AsyncDO(taskFunc TaskFunc) error

AsyncDO 添加任务, 如果有设置

func (*Task) Close

func (task *Task) Close()

Close 关闭协程池

func (Task) CountInfo

func (task Task) CountInfo() map[string]int

CountInfo 获取协程池个数信息

func (*Task) RawGoroutineCount

func (task *Task) RawGoroutineCount() int64

RawGoroutineCount 获取当前执行任务的原生协程数

func (*Task) Reboot

func (task *Task) Reboot()

Reboot 重启关闭的协程池

type TaskFunc

type TaskFunc func()