chantask

Documentation

Index

• type ChanTask
  • func NewChanTask(maxCache int) *ChanTask
  • func (this *ChanTask) IsTerminated() bool
  • func (this *ChanTask) PushTask(fn func(args ...interface{}), args ...interface{}) error
  • func (this *ChanTask) Remain() int32
  • func (this *ChanTask) StatusString() string
  • func (this *ChanTask) Stop()
• type ChanTaskHub
  • func NewChanTaskHub() *ChanTaskHub
  • func (this *ChanTaskHub) CheckGetChanTask(id string, maxcache int, priority int) (task *ChanTask, refcnt int32)
  • func (this *ChanTaskHub) ReleaseChanTask(id string) bool
  • func (this *ChanTaskHub) StatusDetails(all int) string

Types

type ChanTask

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

func NewChanTask

func NewChanTask(maxCache int) *ChanTask

func (*ChanTask) IsTerminated

func (this *ChanTask) IsTerminated() bool

func (*ChanTask) PushTask

func (this *ChanTask) PushTask(fn func(args ...interface{}), args ...interface{}) error

func (*ChanTask) Remain

func (this *ChanTask) Remain() int32

func (*ChanTask) StatusString

func (this *ChanTask) StatusString() string

func (*ChanTask) Stop

func (this *ChanTask) Stop()

type ChanTaskHub

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

var (
	DefaultChanTaskHub *ChanTaskHub
)

func NewChanTaskHub

func NewChanTaskHub() *ChanTaskHub

func (*ChanTaskHub) CheckGetChanTask

func (this *ChanTaskHub) CheckGetChanTask(id string, maxcache int, priority int) (task *ChanTask, refcnt int32)

func (*ChanTaskHub) ReleaseChanTask

func (this *ChanTaskHub) ReleaseChanTask(id string) bool

false: 不存在, 或者有引用 true: 停止成功

func (*ChanTaskHub) StatusDetails

func (this *ChanTaskHub) StatusDetails(all int) string