Versions in this module Expand all Collapse all v1 v1.0.1 Nov 16, 2024 Changes in this version + type Concurrent struct + func NewConcurrent() *Concurrent + func (c *Concurrent) AsyncDo(f func() bool, cb func(err error)) + func (c *Concurrent) AsyncDoByQueue(queueId int64, fn func() bool, cb func(err error)) + func (c *Concurrent) Close() + func (c *Concurrent) GetCallBackChannel() chan func(error) + func (c *Concurrent) OpenConcurrent(minGoroutineNum int32, maxGoroutineNum int32, maxTaskChannelNum int) + func (c *Concurrent) OpenConcurrentByNumCPU(cpuNumMul float32) + func (d *Concurrent) DoCallback(cb func(err error)) + type IConcurrent interface + AsyncDo func(f func() bool, cb func(err error)) + AsyncDoByQueue func(queueId int64, fn func() bool, cb func(err error)) + OpenConcurrent func(minGoroutineNum int32, maxGoroutineNum int32, maxTaskChannelNum int) + OpenConcurrentByNumCPU func(cpuMul float32)
Go to main page