perf: concurrent deletion of top-level directories

Author: markthree

fs.go

@@ -25,8 +25,6 @@ func RemoveAll(f string) error {
 	}
 
 	entrysLen := len(entrys)
-
-	signal := struct{}{}
 	errChan := make(chan error)
 	signalChan := make(chan struct{}, entrysLen)
 	resolve, reject, status := StatusPromise(signalChan, errChan)
@@ -40,15 +38,15 @@ func RemoveAll(f string) error {
 					reject(err)
 					return
 				}
-				resolve(signal)
+				resolve(NoopSignal)
 				return
 			}
 			err := RemoveAll(p)
 			if err != nil {
 				reject(err)
 				return
 			}
-			resolve(signal)
+			resolve(NoopSignal)
 		}(entrys[i])
 	}
 

main.go

@@ -43,21 +43,36 @@ func main() {
 		os.Exit(0)
 	}
 
-	cache_dirs := []string{".nuxt", "cache", ".cache", "@cache", "temp", ".temp", "@temp"}
+	cacheDirs := []string{".nuxt", "cache", ".cache", "@cache", "temp", ".temp", "@temp"}
 
-	withDist(&cache_dirs)
+	withDist(&cacheDirs)
 
-	withNodeModules(&cache_dirs)
+	withNodeModules(&cacheDirs)
 
-	for _, v := range cache_dirs {
-		if !IsExist(v) || !IsDir(v) {
-			continue
-		}
-		err := RemoveAll(v)
-		if err != nil {
-			color.Red("remove fail: %v \nroot: %v", err, v)
-		} else {
-			color.Green("remove success: %v", v)
-		}
+	cacheDirsLen := len(cacheDirs)
+
+	errChan := make(chan error)
+	signalChan := make(chan struct{}, cacheDirsLen)
+	resolve, reject, status := StatusPromise(signalChan, errChan)
+
+	for _, v := range cacheDirs {
+		go func(dir string) {
+			if !IsExist(dir) || !IsDir(dir) {
+				resolve(NoopSignal)
+				return
+			}
+			err := RemoveAll(dir)
+			if err != nil {
+				reject(err)
+				color.Red("remove fail: %v \nroot: %v", err, dir)
+			} else {
+				resolve(NoopSignal)
+				color.Green("remove success: %v", dir)
+			}
+		}(v)
+	}
+
+	for i := 0; i < cacheDirsLen; i++ {
+		status()
 	}
 }

promise.go utils.gopromise.go renamed to utils.go

@@ -1,5 +1,7 @@
 package main
 
+var NoopSignal = struct{}{}
+
 func StatusPromise[T any](ch chan T, err chan error) (func(T), func(error), func() (T, error)) {
 	resolve := func(result T) {
 		ch <- result