queue

package

v0.0.0-...-8301186 Latest Latest Go to latest Published: Sep 7, 2021 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrInvalidBlockSize = errors.New("invalid block size")
	ErrInvalidDataSize  = errors.New("invalid block data size : too long")
)

This section is empty.

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

func NewMultiQueue(shm *model.Mem, size int) (*MultiQueue, error)

func (multiArray *MultiQueue) Get() ([][]byte, error)

func (multiArray *MultiQueue) Save(buf []byte) error

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

一个生产者 & 一个消费者的情况之下生产者只修改 writeIndex，消费者只修改 readIndex 由此不需要使用 atomic 包操作

func NewRingQueue(shm *model.Mem, size int) (*RingQueue, error)

func (rq *RingQueue) Get() ([][]byte, error)

func (rq *RingQueue) Save(data []byte) error