gpool

package

v0.2.0 Latest Latest Go to latest Published: Jan 5, 2025 License: MPL-2.0 Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewTaskPool(size int) *Pool

func (p *Pool) Close()

Close 关闭通道释放资源,

func (p *Pool) GetSize() uint64

func (p *Pool) Running() uint64

Running 获取Runing状态的协程数

func (p *Pool) Submit(task func()) error

Submit 提交任务到task通道中