go_pool

Documentation

Index

• func DefaultOptions() *options
• func NewGoAsyncDo(f GoAsyncFunc, args ...any)
• func NewGoSyncDo(f GoSyncFunc, args ...any) (any, error)
• type GoAsyncFunc
• type GoRunners
  • func NewGoRunners(ops ...*options) GoRunners
• type GoSyncFunc

Functions

func DefaultOptions

func DefaultOptions() *options

func NewGoAsyncDo

func NewGoAsyncDo(f GoAsyncFunc, args ...any)

func NewGoSyncDo

func NewGoSyncDo(f GoSyncFunc, args ...any) (any, error)

Types

type GoAsyncFunc

type GoAsyncFunc = func(...any)

type GoRunners

type GoRunners interface {
	// SyncRun 同步执行一个任务
	SyncRun(GoSyncFunc, ...any) (any, error)
	// AsyncRun 异步执行一个任务
	AsyncRun(GoAsyncFunc, ...any) error
}

func NewGoRunners

func NewGoRunners(ops ...*options) GoRunners

type GoSyncFunc

type GoSyncFunc = func(...any) (any, error)