taskpool

package

v1.6.12 Latest Latest Go to latest Published: Jul 14, 2026 License: MIT Imports: 5 Imported by: 12

Details

This section is empty.

This section is empty.

This section is empty.

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

IOTaskPool .

func NewIO(concurrent, queueSize, bufSize int, v ...interface{}) *IOTaskPool

NewIO creates and returns a IOTaskPool.

func (tp *IOTaskPool) Call(f func(*[]byte))

Call .

func (tp *IOTaskPool) Go(f func(*[]byte))

Go .

func (tp *IOTaskPool) Stop()

Stop .

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

TaskPool .

func New(maxConcurrent int, chQqueueSize int, v ...interface{}) *TaskPool

New creates and returns a TaskPool.

func (tp *TaskPool) Call(f func())

Call .

func (tp *TaskPool) Go(f func())

Go .

func (tp *TaskPool) Stop()

Stop .