shmqueue

Documentation

Index

• Variables
• type BinarySem
  • func NewBinarySem() BinarySem
• type BinarySemphore
  • func (b BinarySemphore) Destroy()
  • func (b BinarySemphore) Give(force bool)
  • func (b BinarySemphore) Take() bool
• type CounterSem
  • func NewCounterSem(n int, init int) CounterSem
• type CounterSemphore
  • func (c CounterSemphore) Destroy()
  • func (c CounterSemphore) Give(force bool)
  • func (c CounterSemphore) Take() bool
• type ShmQueue
  • func New(segmentSize int, total int) (ShmQueue, error)
• type ShmQueue2
  • func NewShmQueue2(segmentSize int, total int) (ShmQueue2, error)

Variables

var (
	ErrBlockR   = errors.New("BlockR")
	ErrBlockW   = errors.New("BlockW")
	ErrEOF      = errors.New("EOF")
	ErrTruncate = errors.New("truncate")
)

Types

type BinarySem

type BinarySem interface {
	Take() bool
	Give(bool)
	Destroy()
}

func NewBinarySem

func NewBinarySem() BinarySem

type BinarySemphore

type BinarySemphore chan struct{}

func (BinarySemphore) Destroy

func (b BinarySemphore) Destroy()

func (BinarySemphore) Give

func (b BinarySemphore) Give(force bool)

func (BinarySemphore) Take

func (b BinarySemphore) Take() bool

type CounterSem

type CounterSem interface {
	Take() bool
	Give(bool)
	Destroy()
}

func NewCounterSem

func NewCounterSem(n int, init int) CounterSem

type CounterSemphore

type CounterSemphore chan struct{}

func (CounterSemphore) Destroy

func (c CounterSemphore) Destroy()

func (CounterSemphore) Give

func (c CounterSemphore) Give(force bool)

func (CounterSemphore) Take

func (c CounterSemphore) Take() bool

type ShmQueue

type ShmQueue interface {
	Push([]byte) error
	Pop([]byte) error
	Destroy()
}

func New

func New(segmentSize int, total int) (ShmQueue, error)

type ShmQueue2

type ShmQueue2 interface {
	Push([]byte) error
	Pop([]byte) error
	Destroy()
}

func NewShmQueue2

func NewShmQueue2(segmentSize int, total int) (ShmQueue2, error)