syncq

package

v1.3.14 Latest Latest Go to latest Published: Dec 5, 2025 License: MIT Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type SyncQueue struct {
	// contains filtered or unexported fields
}

SyncQueue Synchronous FIFO queue

func NewSyncQueue() *SyncQueue

NewSyncQueue Create a new SyncQueue

func (q *SyncQueue) Close()

Close SyncQueue

After close, Pop will return nil without block, and TryPop will return v=nil, ok=True

func (q *SyncQueue) Len() (l int)

Len Get the length of SyncQueue

func (q *SyncQueue) Pop() (v any)

Pop an item from SyncQueue, will block if SyncQueue is empty

func (q *SyncQueue) Push(v any)

Push an item to SyncQueue. Always returns immediately without blocking

func (q *SyncQueue) TryPop() (v any, ok bool)

TryPop Try to pop an item from SyncQueue, will return immediately with bool=false if SyncQueue is empty