eventloop

Documentation

Index

• type EventLoop
  • func New() (*EventLoop, error)
  • func (l *EventLoop) AddSocketAndEnableRead(fd int, s Socket) error
  • func (l *EventLoop) DeleteFdInLoop(fd int)
  • func (l *EventLoop) EnableRead(fd int) error
  • func (l *EventLoop) EnableReadWrite(fd int) error
  • func (l *EventLoop) PacketBuf() []byte
  • func (l *EventLoop) QueueInLoop(f func())
  • func (l *EventLoop) RunLoop()
  • func (l *EventLoop) Stop() error
• type Socket

Types

type EventLoop

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

EventLoop：事件循环

func New

func New() (*EventLoop, error)

New：创建一个 EventLoop

func (*EventLoop) AddSocketAndEnableRead

func (l *EventLoop) AddSocketAndEnableRead(fd int, s Socket) error

AddSocketAndEnableRead：增加 Socket 到事件循环中，并注册可读事件

func (*EventLoop) DeleteFdInLoop

func (l *EventLoop) DeleteFdInLoop(fd int)

DeleteFdInLoop：删除 fd

func (*EventLoop) EnableRead

func (l *EventLoop) EnableRead(fd int) error

EnableRead：使能可写事件

func (*EventLoop) EnableReadWrite

func (l *EventLoop) EnableReadWrite(fd int) error

EnableReadWrite：使能可读可写事件

func (*EventLoop) PacketBuf

func (l *EventLoop) PacketBuf() []byte

PacketBuf：内部使用，临时缓冲区

func (*EventLoop) QueueInLoop

func (l *EventLoop) QueueInLoop(f func())

QueueInLoop：添加 func 到事件循环中执行

func (*EventLoop) RunLoop

func (l *EventLoop) RunLoop()

RunLoop：启动事件循环

func (*EventLoop) Stop

func (l *EventLoop) Stop() error

Stop：关闭事件循环

type Socket

type Socket interface {
	HandleEvent(fd int, events poller.Event)
	Close() error
}

Socket：socket 接口