workerpool

package

v0.0.0-...-30b4b00 Latest Latest Go to latest Published: Aug 5, 2026 License: AGPL-3.0 Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

func Init(workers, queueSize int)

Init 初始化全局 Worker Pool

func Shutdown()

Shutdown 优雅关闭，等待所有任务完成

func Submit(task Task)

Submit 提交异步任务（非阻塞，队列满时丢弃并打印警告）

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

Pool 轻量级 Worker Pool

type Task func(ctx context.Context)

Task 异步任务函数类型