basic_event_queue

Documentation

Index

• type EventQueue
  • func NewEventQueue(queueSize int) *EventQueue
  • func (loop *EventQueue) MustPut(f func())
  • func (loop *EventQueue) Put(f func()) error
  • func (loop *EventQueue) Run()
  • func (loop *EventQueue) Stop()
  • func (loop *EventQueue) StopAsync() (done <-chan struct{})

Types

type EventQueue

type EventQueue struct {
	sync.Once
	// contains filtered or unexported fields
}

func NewEventQueue

func NewEventQueue(queueSize int) *EventQueue

func (*EventQueue) MustPut

func (loop *EventQueue) MustPut(f func())

func (*EventQueue) Put

func (loop *EventQueue) Put(f func()) error

func (*EventQueue) Run

func (loop *EventQueue) Run()

func (*EventQueue) Stop

func (loop *EventQueue) Stop()

func (*EventQueue) StopAsync

func (loop *EventQueue) StopAsync() (done <-chan struct{})