taskpool

Documentation

Index

• type TaskPool
  • func New(maxConcurrent int, chQqueueSize int, v ...interface{}) *TaskPool
  • func (tp *TaskPool) Go(f func())
  • func (tp *TaskPool) Stop()

Types

type TaskPool

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

TaskPool .

func New

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

New .

func (*TaskPool) Go

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

Go .

func (*TaskPool) Stop

func (tp *TaskPool) Stop()

Stop .