thread

Documentation

Index

• Constants
• func Go(task func())
• func GoByID[T int | int32 | int64](goID T, task func())
• func GoMain(task func())
• func InitPool(p *ants.PoolWithID) error
• func PoolInstance() *ants.PoolWithID
• func ReleaseTableGoPool()
• func WaitByID[T int | int32 | int64](goID T, task func())
• func WaitMain(task func())

Constants

const DefaultTaskBuffer = 100

const MainThreadID = math.MaxInt // 主线程ID

Functions

func Go

func Go(task func())

Go 从默认线程池获取一个goroutine并派发任务

@param task

func GoByID

func GoByID[T int | int32 | int64](goID T, task func())

GoByID 根据指定的goroutineID派发线程

@receiver h
@param goID 若>0,派发到指定线程,否则随机派发
@param task

func GoMain

func GoMain(task func())

GoMain 派发到主线程

@param task

func InitPool

func InitPool(p *ants.PoolWithID) error

InitPool 用默认参数初始化全局线程池

func PoolInstance

func PoolInstance() *ants.PoolWithID

func ReleaseTableGoPool

func ReleaseTableGoPool()

func WaitByID

func WaitByID[T int | int32 | int64](goID T, task func())

func WaitMain

func WaitMain(task func())

WaitMain 派发到主线程并等待执行完成

@param task