Versions in this module Expand all Collapse all v0 v0.0.2 Nov 24, 2019 v0.0.1 Nov 19, 2019 Changes in this version + type BacklogPool interface + EnqueueBacklog func(enqueueCtx context.Context, t ExecFunc, arg interface{}, out chan interface{}) error + IsFull func() bool + func MakeBacklog(execPool ExecutionPool, backlogSize int, priority Priority, owner interface{}) BacklogPool + type ExecFunc func(interface{}) interface + type ExecutionPool interface + Enqueue func(enqueueCtx context.Context, t ExecFunc, arg interface{}, i Priority, ...) error + GetOwner func() interface{} + GetParallelism func() int + Shutdown func() + func MakePool(owner interface{}) ExecutionPool + type Priority uint8 + const HighPriority + const LowPriority
Go to main page