pools

Documentation

Index

• type Config
  • func (this Config) String() string
• type Logger
  • func (this *Logger) Printf(format string, args ...any)
• type Poolmgr
  • func NewPoolmgr() *Poolmgr
  • func (this *Poolmgr) Finalize()
  • func (this *Poolmgr) Initialize(config *Config) (err error)
  • func (this *Poolmgr) Status() Stat
  • func (this *Poolmgr) Submit(task func())
• type Stat
  • func (this Stat) String() string

Types

type Config

type Config struct {
	Capacity     int                              `yaml:"capacity"`    // 執行緒池容量, 0表示容量無限
	Expire       time.Duration                    `yaml:"expire"`      // 執行緒超時時間, 詳細說明請查看ants.Options.ExpiryDuration的說明
	PreAlloc     bool                             `yaml:"preAlloc"`    // 是否預先分配記憶體, 詳細說明請查看ants.Options.PreAlloc的說明
	Nonblocking  bool                             `yaml:"nonblocking"` // 是否在執行緒耗盡時阻塞Submit的執行, 詳細說明請查看ants.Options.Nonblocking的說明
	MaxBlocking  int                              `yaml:"maxBlocking"` // 最大阻塞執行緒數量, 0表示無限制, 詳細說明請查看ants.Options.MaxBlockingTasks的說明
	PanicHandler func(any)                        `yaml:"-" json:"-"`  // 失敗處理函式, 詳細說明請查看ants.Options.PanicHandler的說明
	Logger       func(format string, args ...any) `yaml:"-" json:"-"`  // 日誌函式
}

Config 配置資料

func (Config) String

func (this Config) String() string

String 取得字串

type Logger

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

Logger 日誌資料

func (*Logger) Printf

func (this *Logger) Printf(format string, args ...any)

Printf 輸出日誌

type Poolmgr

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

Poolmgr 執行緒池管理器

var DefaultPool *Poolmgr // 預設執行緒池管理器

func NewPoolmgr

func NewPoolmgr() *Poolmgr

NewPoolmgr 建立執行緒池管理器

func (*Poolmgr) Finalize

func (this *Poolmgr) Finalize()

Finalize 結束處理

func (*Poolmgr) Initialize

func (this *Poolmgr) Initialize(config *Config) (err error)

Initialize 初始化處理

func (*Poolmgr) Status

func (this *Poolmgr) Status() Stat

Status 獲得狀態資料

func (*Poolmgr) Submit

func (this *Poolmgr) Submit(task func())

Submit 啟動執行緒

type Stat

type Stat struct {
	Running   int // 執行中的執行緒數量
	Available int // 未使用的執行緒數量
	Capacity  int // 執行緒數量上限
}

Stat 狀態資料

func (Stat) String

func (this Stat) String() string

String 取得字串