zbrun

Documentation

Overview

异步编程抽象模型

Index

• func GetOS() string
• func MainStartup(workdir string, initchild func()) func()
• func MainWait(getio GetIOinfo)
• func NewTimerMgr() any
• type AsynExer
  • func (this *AsynExer) AsynExec(fun func()) (isasyn bool)
  • func (this *AsynExer) AsynRetExec(delayfunc func(deferfunc func())) (isasyn bool)
• type Atomint
• type GetIOinfo
• type IOServer
• type Runner
  • func NewRunner() Runner
• type TimerMgr

Functions

func GetOS

func GetOS() string

func MainStartup

func MainStartup(workdir string, initchild func()) func()

func MainWait

func MainWait(getio GetIOinfo)

func NewTimerMgr

func NewTimerMgr() any

Types

type AsynExer

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

func (*AsynExer) AsynExec

func (this *AsynExer) AsynExec(fun func()) (isasyn bool)

AsynExec 异步执行，suspend_milsec=0为尽量立即执行,suspend_milsec>0为挂起suspend_milsec毫秒后再执行

func (*AsynExer) AsynRetExec

func (this *AsynExer) AsynRetExec(delayfunc func(deferfunc func())) (isasyn bool)

AsynRetExec 异步返回执行

type Atomint

type Atomint interface {
	Load() int32
	Store(val int32)
	CompareAndSwap(old, new int32) (swapped bool)
}

type GetIOinfo

type GetIOinfo interface {
	GetSockNum() int
	GetSendBytes() int64
	GetRecvBytes() int64
}

type IOServer

type IOServer interface {
	GetRefCount() *zbsync.Int32
	GetExitFlag() *zbsync.Int32

	SetReqChan(chan func())
}

type Runner

type Runner interface {
	Atomint
	TimerMgr
	Start(n_concurrency int, ioss ...IOServer)
	Stop(wait4exit bool, after_exit func())
	PostFun(fun func())
}

func NewRunner

func NewRunner() Runner

type TimerMgr

type TimerMgr interface {
	BeginTimer(interval uint, occfunc func() bool)
	RegetNextTimer(pp_timer *any) (delay time.Duration, tmrexefunc func())
	TmMgrClose(wait bool)
}