queue

Jan 5, 2023

Changes in this version

+ type Queue struct

+ func NewBounded(name string, max int) (*Queue, error)

+ func NewUnbounded(name string) (*Queue, error)

+ func (q *Queue) Close()

+ func (q *Queue) DequeueCount() int64

+ func (q *Queue) EnqueueCount() int64

+ func (q *Queue) Receive() chan interface{}

+ func (q *Queue) Run()

+ func (q *Queue) String() string

+ func (q *Queue) Write(v interface{}) error