queue

Sep 29, 2026

Changes in this version

+ const Closed

+ const Hanged

+ const Opened

+ type Queue struct

+ func NewQueue[T any](size int32, timeout time.Duration, rw ...*sync.RWMutex) *Queue[T]

+ func (q *Queue[T]) Clean(f func(T))

+ func (q *Queue[T]) Close()

+ func (q *Queue[T]) Done(isCloseSig bool)

+ func (q *Queue[T]) Read() <-chan T

+ func (q *Queue[T]) Wait()

+ func (q *Queue[T]) Write(t T, block ...bool) (err error)

+ type Tasker struct

+ func NewTasker(size int32, timeout time.Duration, rw ...*sync.RWMutex) *Tasker

+ func (t *Tasker) Clean()

+ func (t *Tasker) Close()

+ func (t *Tasker) Commit(fn func(), wait ...bool) (*sync.WaitGroup, error)

+ func (t *Tasker) Done() error

+ func (t *Tasker) Handle(tk *task, isExecute bool)

+ func (t *Tasker) Read() <-chan *task

+ func (t *Tasker) Wait()