pool

package

v0.0.30 Latest Latest Go to latest Published: Nov 6, 2025 License: MIT Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Pool 封装的 worker pool

func New(size int) (*Pool, error)

New 创建一个新的 worker pool size: 池子大小

func (wp *Pool) Release()

Release 释放资源

func (wp *Pool) Results() <-chan Result

Results 获取结果通道

func (wp *Pool) Submit(task TaskFunc) error

Submit 提交一个任务

func (wp *Pool) Wait()

Wait 等待所有任务完成

type Result struct {
	Value any
	Err   error
}

Result 表示任务执行结果

type TaskFunc func() (any, error)

TaskFunc 定义任务函数