fs: Performance Enhancement: Concurrent Execution of Async Tasks with Promise.all ✈

lib/internal/fs/cp/cp.js

@@ -313,13 +313,16 @@ async function mkDirAndCopy(srcMode, src, dest, opts) {
 
 async function copyDir(src, dest, opts) {
   const dir = await opendir(src);
+  const promises = [];
 
   for await (const { name } of dir) {
     const srcItem = join(src, name);
     const destItem = join(dest, name);
     const { destStat, skipped } = await checkPaths(srcItem, destItem, opts);
-    if (!skipped) await getStatsForCopy(destStat, srcItem, destItem, opts);
+    if (!skipped) PromisePrototypePush(promises, getStatsForCopy(destStat, srcItem, destItem, opts));
   }
+
+  await SafePromiseAllReturnVoid(promises);
 }
 
 async function onLink(destStat, src, dest, opts) {

lib/internal/fs/recursive_watch.js

@@ -140,6 +140,7 @@ class FSWatcher extends EventEmitter {
 
     try {
       const files = await opendir(folder);
+      const promises = [];
 
       for await (const file of files) {
         if (this.#closed) {
@@ -159,10 +160,11 @@ class FSWatcher extends EventEmitter {
           if (file.isFile()) {
             this.#watchFile(f);
           } else if (file.isDirectory() && !file.isSymbolicLink()) {
-            await this.#watchFolder(f);
+            PromisePrototypePush(promises, this.#watchFolder(f));
           }
         }
       }
+      await SafePromiseAllReturnVoid(promises);
     } catch (error) {
       this.emit('error', error);
     }

lib/internal/main/watch_mode.js

@@ -112,14 +112,16 @@ async function restart() {
 
 (async () => {
   emitExperimentalWarning('Watch mode');
+  const promises = [];
 
   try {
     start();
 
     // eslint-disable-next-line no-unused-vars
     for await (const _ of on(watcher, 'changed')) {
-      await restart();
+      PromisePrototypePush(promises, restart());
     }
+    await SafePromiseAllReturnVoid(promises);
   } catch (error) {
     triggerUncaughtException(error, true /* fromPromise */);
   }