zbrun

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

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

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

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

	SetReqChan(chan func())
}

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

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