pool

package

v0.59.0 Latest Latest Go to latest Published: May 20, 2026 License: MIT Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewAsyncPool(taskBufferCapacity int, numWorkers int) (*AsyncPool, error)

NewAsyncPool creates a new AsyncPool. taskBufferCapacity is the capacity of the task buffer. numWorkers is the number of workers in the pool.

func (ap *AsyncPool) AsyncSubmit(task Task, onError OnError) error

AsyncSubmit submits a task asynchronously.

If the task buffer is full, it will return an error. If the pool is closed, it will return an error.

Task type: func() error

OnError type: func(error)

func (ap *AsyncPool) Shutdown()

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

func NewAsyncPoolV2(maxWorkers int32, queueSize int) (*AsyncPoolV2, error)

func (ts *AsyncPoolV2) AsyncSubmit(ctx context.Context, task TaskWithCtx, onError OnError) error

func (ts *AsyncPoolV2) Shutdown()

func (ts *AsyncPoolV2) Stats() any

type OnError func(error)

type Stats struct {
	Running   *int64 // 当前运行中的任务数
	Pending   *int64 // 等待中的任务数
	Completed *int64 // 已成功完成的任务数
	Failed    *int64 // 执行失败（包括超时）的任务数
}

Stats 保存调度器的统计信息

func NewStats() *Stats

type Task func() error

type TaskWithCtx func(ctx context.Context) error

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

func NewWorkerPool(numWorkers int) *WorkerPool

func (wp *WorkerPool) Submit(task Task, onError OnError)

func (wp *WorkerPool) TrySubmit(task Task, onError OnError) bool