grpool

package
v0.0.0-...-f86ead6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 17, 2019 License: MIT Imports: 1 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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))

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL