queue

Documentation

Overview

* @Author: cnzf1 * @Date: 2022-12-12 15:22:54 * @LastEditors: cnzf1 * @LastEditTime: 2022-12-13 14:45:01 * @Description:

Index

• type EventHandler
  • func NewEventHandler(h HandlerFunc, size ...int) *EventHandler
  • func (e *EventHandler) Len() int
  • func (e *EventHandler) Push(req lang.AnyType)
  • func (e *EventHandler) Stop()
• type HandlerFunc
• type Queue
  • func NewQueue() *Queue
  • func (q *Queue) Add(item interface{})
  • func (q *Queue) Done(item interface{})
  • func (q *Queue) Get() (item interface{}, shutdown bool)
  • func (q *Queue) Len() int
  • func (q *Queue) ProcessingLen() int
  • func (q *Queue) ShutDown()
  • func (q *Queue) ShutDownWithDrain()
  • func (q *Queue) ShuttingDown() bool

Types

type EventHandler

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

func NewEventHandler

func NewEventHandler(h HandlerFunc, size ...int) *EventHandler

func (*EventHandler) Len

func (e *EventHandler) Len() int

func (*EventHandler) Push

func (e *EventHandler) Push(req lang.AnyType)

Push a request msg to handler

func (*EventHandler) Stop

func (e *EventHandler) Stop()

type HandlerFunc

type HandlerFunc func(lang.AnyType)

type Queue

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

func NewQueue

func NewQueue() *Queue

func (*Queue) Add

func (q *Queue) Add(item interface{})

func (*Queue) Done

func (q *Queue) Done(item interface{})

func (*Queue) Get

func (q *Queue) Get() (item interface{}, shutdown bool)

func (*Queue) Len

func (q *Queue) Len() int

func (*Queue) ProcessingLen

func (q *Queue) ProcessingLen() int

func (*Queue) ShutDown

func (q *Queue) ShutDown()

func (*Queue) ShutDownWithDrain

func (q *Queue) ShutDownWithDrain()

func (*Queue) ShuttingDown

func (q *Queue) ShuttingDown() bool