taskpool

Documentation

Index

• type IOTaskPool
  • func NewIO(concurrent, queueSize, bufSize int, v ...interface{}) *IOTaskPool
  • func (tp *IOTaskPool) Call(f func(*[]byte))
  • func (tp *IOTaskPool) Go(f func(*[]byte))
  • func (tp *IOTaskPool) Stop()
• type TaskPool
  • func New(maxConcurrent int, chQqueueSize int, v ...interface{}) *TaskPool
  • func (tp *TaskPool) Call(f func())
  • func (tp *TaskPool) Go(f func())
  • func (tp *TaskPool) Stop()

Types

type IOTaskPool

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

IOTaskPool .

func NewIO

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

NewIO creates and returns a IOTaskPool.

func (*IOTaskPool) Call

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

Call .

func (*IOTaskPool) Go

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

Go .

func (*IOTaskPool) Stop

func (tp *IOTaskPool) Stop()

Stop .

type TaskPool

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

TaskPool .

func New

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

New creates and returns a TaskPool.

func (*TaskPool) Call

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

Call .

func (*TaskPool) Go

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

Go .

func (*TaskPool) Stop

func (tp *TaskPool) Stop()

Stop .