concurrent

Documentation

Index

• func ConcurrentExecute(ctx context.Context, ids []int64, task func(context.Context, int64) error, ...) error

Functions

func ConcurrentExecute

func ConcurrentExecute(
	ctx context.Context,
	ids []int64,
	task func(context.Context, int64) error,
	maxConcurrent ...int,
) error

ConcurrentExecute is a general-purpose concurrent execution function Parameters: - ctx: Context - ids: List of IDs to process - task: Function to process a single ID (additional parameters can be captured via closures if needed) - maxConcurrent: Maximum concurrency (default 20, adjustable based on business needs) Returns: Aggregated error message containing all failed IDs and their errors