coroutineGroup

package

v1.63.11 Latest Latest Go to latest Published: Jan 23, 2026 License: Apache-2.0 Imports: 3 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrBatchInvalid    = errors.New("轮数不能为0")
	ErrCapacityInvalid = errors.New("每轮循环数不能为0")
)

func GetBatches(total, capacities int) uint

GetBatches 计算批次数

type CoroutineGroup[T any] struct {
	Error   error
	OK      bool
	Results []*Result[T]
	// contains filtered or unexported fields
}

func NewCoroutineGroup[T any]() *CoroutineGroup[T]

NewCoroutineGroup 创建协程组实例

func (my *CoroutineGroup[T]) GO(fn func(batch, capacity uint) (result *Result[T])) *CoroutineGroup[T]

GO 执行协程组

func (my *CoroutineGroup[T]) SetBatches(batches uint) *CoroutineGroup[T]

SetBatches 设置批次数

func (my *CoroutineGroup[T]) SetBatchesByCapacities(total, capacities int) *CoroutineGroup[T]

SetBatchesByCapacities 根据总数和每批次容量计算批次数并设置

func (my *CoroutineGroup[T]) SetCapacity(capacities uint) *CoroutineGroup[T]

SetCapacity 设置每批次容量

type Result[T any] struct {
	Data   T
	Error  error
	IsSkip bool
}