gopool

Documentation

Index

• type GoPool
  • func NewPool(minlimit int64, maxlimit int64) *GoPool
  • func NewPoolWithFuncLimit(minlimit int64, maxlimit int64, FuncLimit int) *GoPool
  • func (g *GoPool) Close()
  • func (g *GoPool) Go(f func())
  • func (g *GoPool) NumUnExecu() int
  • func (g *GoPool) TurnOff(off bool)

Types

type GoPool

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

func NewPool

func NewPool(minlimit int64, maxlimit int64) *GoPool

func NewPoolWithFuncLimit

func NewPoolWithFuncLimit(minlimit int64, maxlimit int64, FuncLimit int) *GoPool

func (*GoPool) Close

func (g *GoPool) Close()

Close when Close ,the pool will enable goroutine, and the func in the pool will be started with goroutine

func (*GoPool) Go

func (g *GoPool) Go(f func())

func (*GoPool) NumUnExecu

func (g *GoPool) NumUnExecu() int

NumUnExecu the number of functions not executed

func (*GoPool) TurnOff

func (g *GoPool) TurnOff(off bool)