grpool

Documentation

Index

• func ChunkCount(total, step int) int
• func Concurrent(jobs func(pool *GRPool))
• func ConcurrentAddWait(jobs func(pool *GRPool))
• func ConcurrentAutoWait(total, step int, jobs func(pool *GRPool))
• func GoroutineRun(job func())
• type GRPool
  • func NewGRPool(workersNum, jobQueueLen int) *GRPool
  • func (e *GRPool) Concurrent(jobs func(pool *GRPool))
  • func (e *GRPool) ConcurrentAddWait(jobs func(pool *GRPool))
  • func (e *GRPool) ConcurrentAutoWait(total, step int, jobs func(pool *GRPool))

Functions

func ChunkCount

func ChunkCount(total, step int) int

func Concurrent

func Concurrent(jobs func(pool *GRPool))

func ConcurrentAddWait

func ConcurrentAddWait(jobs func(pool *GRPool))

func ConcurrentAutoWait

func ConcurrentAutoWait(total, step int, jobs func(pool *GRPool))

func GoroutineRun

func GoroutineRun(job func())

Types

type GRPool

type GRPool struct {
	*grpool.Pool
}

func NewGRPool

func NewGRPool(workersNum, jobQueueLen int) *GRPool

func (*GRPool) Concurrent

func (e *GRPool) Concurrent(jobs func(pool *GRPool))

func (*GRPool) ConcurrentAddWait

func (e *GRPool) ConcurrentAddWait(jobs func(pool *GRPool))

func (*GRPool) ConcurrentAutoWait

func (e *GRPool) ConcurrentAutoWait(total, step int, jobs func(pool *GRPool))