cuba

Sep 16, 2019

Changes in this version

+ const POOL_ABORT

+ const POOL_FINISH

+ const POOL_RUN

+ var PoolAbortedErr = errors.New("pool has been aborted")

type Bucket

+ IsEmpty func() bool

type Pool

+ func (pool *Pool) Abort()

type Queue

+ func (queue *Queue) IsEmpty() bool

type Stack

+ func (stack *Stack) IsEmpty() bool

Aug 11, 2019

Changes in this version

+ type Bucket interface

+ Empty func() bool

+ Pop func() interface{}

+ Push func(interface{})

+ PushAll func([]interface{})

+ type Handle struct

+ func (handle *Handle) Item() interface{}

+ func (handle *Handle) Push(item interface{})

+ func (handle *Handle) Sync()

+ type Pool struct

+ func New(task Task, bucket Bucket) *Pool

+ func (pool *Pool) Finish()

+ func (pool *Pool) Push(item interface{})

+ func (pool *Pool) PushAll(items []interface{})

+ func (pool *Pool) SetMaxWorkers(n int32)

+ type Queue struct

+ func NewQueue() *Queue

+ func (queue *Queue) Empty() bool

+ func (queue *Queue) Pop() interface{}

+ func (queue *Queue) Push(item interface{})

+ func (queue *Queue) PushAll(items []interface{})

+ type Stack struct

+ func (stack *Stack) Empty() bool

+ func (stack *Stack) Pop() interface{}

+ func (stack *Stack) Push(item interface{})

+ func (stack *Stack) PushAll(items []interface{})

+ type Task func(*Handle)

Aug 3, 2019

Changes in this version

+ type CubaFunc func(interface{}) []interface

+ type CubaStack struct

+ func NewStack(worker CubaFunc) *CubaStack

+ func (ws *CubaStack) Close()

+ func (ws *CubaStack) Next() (interface{}, bool)

+ func (ws *CubaStack) Push(items []interface{})

+ func (ws *CubaStack) Run()