pool

package

v0.55.0 Latest Latest Go to latest Published: May 14, 2026 License: MIT Imports: 5 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 OnError func(error)

type Task func() 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