sync

Sep 1, 2016

Changes in this version

+ type ExclusivePool struct

+ func NewExclusivePool() *ExclusivePool

+ func (p *ExclusivePool) CheckIn(identity string)

+ func (p *ExclusivePool) CheckOut(identity string)

+ type StatusTable struct

+ func NewStatusTable() *StatusTable

+ func (p *StatusTable) IsRunning(name string) bool

+ func (p *StatusTable) Start(name string)

+ func (p *StatusTable) Stop(name string)

+ type UniqueQueue struct

+ func NewUniqueQueue(queueLength int) *UniqueQueue

+ func (q *UniqueQueue) Add(id interface{})

+ func (q *UniqueQueue) AddFunc(id interface{}, fn func())

+ func (q *UniqueQueue) Exist(id interface{}) bool

+ func (q *UniqueQueue) Queue() <-chan string

+ func (q *UniqueQueue) Remove(id interface{})