module

package
v1.1.43 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 8, 2023 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Destroy

func Destroy()

func Init

func Init()

func Register

func Register(mi Module)

Types

type Module

type Module interface {
	OnInit()
	OnDestroy()
	Run(closeSig chan bool)
}

type Skeleton

type Skeleton struct {
	GoLen              int
	TimerDispatcherLen int
	AsynCallLen        int
	ChanRPCServer      *chanrpc.Server
	// contains filtered or unexported fields
}

func (*Skeleton) AfterFunc

func (s *Skeleton) AfterFunc(d time.Duration, cb func()) *timer.Timer

func (*Skeleton) AsynCall

func (s *Skeleton) AsynCall(server *chanrpc.Server, id interface{}, args ...interface{})

func (*Skeleton) CronFunc

func (s *Skeleton) CronFunc(cronExpr *timer.CronExpr, cb func()) *timer.Cron

func (*Skeleton) Go

func (s *Skeleton) Go(f func(), cb func())

func (*Skeleton) Init

func (s *Skeleton) Init()

func (*Skeleton) LoopFunc added in v1.1.9

func (s *Skeleton) LoopFunc(d time.Duration, cb func()) *timer.Cron

LoopFunc 由于循环队列只支持cron表达式,而cron表达式最少只有到秒级别,游戏中同步一般都是毫秒级别,所以在此添加毫秒级别的循环队列

func (*Skeleton) NewLinearContext

func (s *Skeleton) NewLinearContext() *g.LinearContext

func (*Skeleton) RegisterChanRPC

func (s *Skeleton) RegisterChanRPC(id interface{}, f interface{})

func (*Skeleton) Run

func (s *Skeleton) Run(closeSig chan bool)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL