async

package

v1.2.2 Latest Latest Go to latest Published: Apr 1, 2026 License: MIT Imports: 4 Imported by: 0

Details

View Source

const (
	STATUS_RUN  = 1
	STATUS_STOP = 2
)

This section is empty.

This section is empty.

type Async struct {
	sync.WaitGroup
	// contains filtered or unexported fields
}

func NewAsync() *Async

func NewAsyncPool(size int) (rets []*Async)

func (d *Async) Push(task func())

添加任务

func (d *Async) Start()

开始actor任务协程

func (d *Async) Stop()

停止actor任务协程

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

func NewQueue() *Queue

func NewQueuePool(size int64) (rets []*Queue)

func (d *Queue) GetCount() int64

func (d *Queue) Pop() (ret interface{})

单协程安全

func (d *Queue) Push(val interface{})

多协程安全