zbrun

Documentation

Overview

异步编程抽象模型

Index

• 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 IOServer
• type Runner
  • func NewRunner() Runner
• type TimerMgr

Functions

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 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)
}