pool

Documentation

Index

• func RoutingPoolWithAutomatic(worker func(context.CancelFunc), max int) (context.CancelFunc, chan struct{})
• func RoutingPoolWithTimer(worker func(context.CancelFunc), max int) (context.CancelFunc, chan struct{})

Functions

func RoutingPoolWithAutomatic

func RoutingPoolWithAutomatic(worker func(context.CancelFunc), max int) (context.CancelFunc, chan struct{})

RoutingPoolWithAutomatic defined routing pool for work Example i := 0

_, done := pool.RoutingPoolWithAutomatic(func(cancel context.CancelFunc) {
	time.Sleep(10 * time.Second)
	i++
	if i == 30 {
		cancel()
	}
}, 10)

<-done

func RoutingPoolWithTimer

func RoutingPoolWithTimer(worker func(context.CancelFunc), max int) (context.CancelFunc, chan struct{})

RoutingPoolWithTimer defined routing pool for work Example i := 0

_, done := pool.RoutingPoolWithTimer(func(cancel context.CancelFunc) {
	time.Sleep(10 * time.Second)
	i++
	if i == 30 {
		cancel()
	}
}, 10)

<-done