eventloop

README

#eventloop

通用事件队列 为什么不用无锁队列？因为目前框架无锁队列性能并不比 DoubleBuffQueue 性能高太多。 而且无锁队列目前并没有好的稳定的实现,没有明显优势

Documentation

Index

• type DoubleBuffQueue
  • func NewDoubleBuffQueue(lockOSThread bool) *DoubleBuffQueue
  • func (this_ *DoubleBuffQueue) AfterFunc(duration time.Duration, f func())
  • func (this_ *DoubleBuffQueue) PostEventQueue(e interface{})
  • func (this_ *DoubleBuffQueue) Start(f func(event any), endF ...func())
  • func (this_ *DoubleBuffQueue) Stop()
  • func (this_ *DoubleBuffQueue) Stopped() bool
  • func (this_ *DoubleBuffQueue) Ticker(interval time.Duration, f func() bool)
  • func (this_ *DoubleBuffQueue) UntilFunc(t time.Time, f func())
• type DoubleBuffQueue2
  • func NewDoubleBuffQueue2[T any](lockOSThread bool) *DoubleBuffQueue2[T]
  • func (this_ *DoubleBuffQueue2[T]) PostEventQueue(e T)
  • func (this_ *DoubleBuffQueue2[T]) Start(f func(T), endF ...func())
  • func (this_ *DoubleBuffQueue2[T]) Stop()
  • func (this_ *DoubleBuffQueue2[T]) Stopped() bool

Types

type DoubleBuffQueue

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

func NewDoubleBuffQueue

func NewDoubleBuffQueue(lockOSThread bool) *DoubleBuffQueue

func (*DoubleBuffQueue) AfterFunc

func (this_ *DoubleBuffQueue) AfterFunc(duration time.Duration, f func())

func (*DoubleBuffQueue) PostEventQueue

func (this_ *DoubleBuffQueue) PostEventQueue(e interface{})

func (*DoubleBuffQueue) Start

func (this_ *DoubleBuffQueue) Start(f func(event any), endF ...func())

func (*DoubleBuffQueue) Stop

func (this_ *DoubleBuffQueue) Stop()

func (*DoubleBuffQueue) Stopped

func (this_ *DoubleBuffQueue) Stopped() bool

func (*DoubleBuffQueue) Ticker

func (this_ *DoubleBuffQueue) Ticker(interval time.Duration, f func() bool)

func (*DoubleBuffQueue) UntilFunc

func (this_ *DoubleBuffQueue) UntilFunc(t time.Time, f func())

type DoubleBuffQueue2

type DoubleBuffQueue2[T any] struct {
	// contains filtered or unexported fields
}

func NewDoubleBuffQueue2

func NewDoubleBuffQueue2[T any](lockOSThread bool) *DoubleBuffQueue2[T]

func (*DoubleBuffQueue2[T]) PostEventQueue

func (this_ *DoubleBuffQueue2[T]) PostEventQueue(e T)

func (*DoubleBuffQueue2[T]) Start

func (this_ *DoubleBuffQueue2[T]) Start(f func(T), endF ...func())

func (*DoubleBuffQueue2[T]) Stop

func (this_ *DoubleBuffQueue2[T]) Stop()

func (*DoubleBuffQueue2[T]) Stopped

func (this_ *DoubleBuffQueue2[T]) Stopped() bool