concurrent

Documentation

Index

• type ConcurrentTask
  • func NewConcurrentTask(maxConcurentNum int) *ConcurrentTask
  • func (self *ConcurrentTask) AddTask(task func(...interface{}), params ...interface{})
  • func (self *ConcurrentTask) Cost() int64
  • func (self *ConcurrentTask) Start()
• type ConcurrentTaskDetail

Types

type ConcurrentTask

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

并发任务调度器

func NewConcurrentTask

func NewConcurrentTask(maxConcurentNum int) *ConcurrentTask

func (*ConcurrentTask) AddTask

func (self *ConcurrentTask) AddTask(task func(...interface{}), params ...interface{})

func (*ConcurrentTask) Cost

func (self *ConcurrentTask) Cost() int64

func (*ConcurrentTask) Start

func (self *ConcurrentTask) Start()

type ConcurrentTaskDetail

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