feat: add builtin paralleler pool.

Author: ghosind

all.go

@@ -50,10 +50,14 @@ func AllWithContext(ctx context.Context, funcs ...AsyncFn) ([][]any, error) {
 // all executes the functions asynchronously until all functions have been finished, or the context
 // is done (canceled or timeout).
 func all(parent context.Context, funcs ...AsyncFn) ([][]any, error) {
-	paralleler := new(Paralleler).
-		WithContext(parent)
-
-	paralleler.Add(funcs...)
+	paralleler := builtinPool.Get().(*Paralleler)
+	defer func() {
+		builtinPool.Put(paralleler)
+	}()
+
+	paralleler.
+		WithContext(parent).
+		Add(funcs...)
 
 	return paralleler.Run()
 }

parallel.go

@@ -48,11 +48,15 @@ func ParallelWithContext(
 
 // parallel runs the functions asynchronously with the specified concurrency.
 func parallel(parent context.Context, concurrency int, funcs ...AsyncFn) ([][]any, error) {
-	paralleler := new(Paralleler).
-		WithContext(parent).
-		WithConcurrency(concurrency)
+	paralleler := builtinPool.Get().(*Paralleler)
+	defer func() {
+		builtinPool.Put(paralleler)
+	}()
 
-	paralleler.Add(funcs...)
+	paralleler.
+		WithContext(parent).
+		WithConcurrency(concurrency).
+		Add(funcs...)
 
 	return paralleler.Run()
 }

paralleler.go

@@ -5,6 +5,13 @@ import (
 	"sync"
 )
 
+// builtinPool is the Parallelers pool for built-in functions.
+var builtinPool sync.Pool = sync.Pool{
+	New: func() any {
+		return new(Paralleler)
+	},
+}
+
 // Paralleler is a tool to run the tasks with the specific concurrency, default no concurrency
 // limitation.
 type Paralleler struct {

times.go

@@ -57,7 +57,12 @@ func TimesSeriesWithContext(ctx context.Context, n int, fn AsyncFn) ([][]any, er
 
 // times executes the function n times withe the specified concurrency.
 func times(parent context.Context, n, concurrency int, fn AsyncFn) ([][]any, error) {
-	paralleler := new(Paralleler).
+	paralleler := builtinPool.Get().(*Paralleler)
+	defer func() {
+		builtinPool.Put(paralleler)
+	}()
+
+	paralleler.
 		WithConcurrency(concurrency).
 		WithContext(parent)