perf: add worker pool

go.mod

@@ -1,3 +1,5 @@
 module github.com/markthree/fast-cpy
 
 go 1.20
+
+require github.com/panjf2000/ants v1.3.0

go.sum

@@ -0,0 +1,2 @@
+github.com/panjf2000/ants v1.3.0 h1:8pQ+8leaLc9lys2viEEr8md0U4RN6uOSUCE9bOYjQ9M=
+github.com/panjf2000/ants v1.3.0/go.mod h1:AaACblRPzq35m1g3enqYcxspbbiOJJYaxU2wMpm1cXY=

package.json

@@ -29,6 +29,7 @@
     "build-types": "tsc",
     "build-go": "go build",
     "build-ts": "vite build",
+    "bench": "node bench.mjs",
     "prepublishOnly": "pnpm build",
     "release": "bumpp --push --tag --all && npm publish",
     "build-go-bin": "goreleaser release --snapshot --clean",

src/core.go

@@ -3,12 +3,15 @@ package core
 import (
 	"fmt"
 	"io"
-	"io/fs"
 	"os"
 	"path"
 	"sync"
+
+	"github.com/panjf2000/ants"
 )
 
+var pool, _ = ants.NewPool(1000000)
+
 func Exists(path string) bool {
 	_, err := os.Stat(path)
 	if err != nil {
@@ -61,7 +64,8 @@ func Copy(src, dest string) {
 	wg.Add(entrysLen)
 
 	for i := 0; i < entrysLen; i++ {
-		go func(entry fs.DirEntry) {
+		entry := entrys[i]
+		ants.Submit(func() {
 			defer wg.Done()
 
 			n := entry.Name()
@@ -108,7 +112,7 @@ func Copy(src, dest string) {
 
 				io.Copy(dstFile, srcFile)
 			}
-		}(entrys[i])
+		})
 	}
 
 	wg.Wait()