check

Author: masx200

check.ts

@@ -1,45 +1,66 @@
 import { parse, walk } from "./deps.ts";
-
-// Async
-async function printFilesNames({ skip }: { skip?: RegExp | RegExp[] }) {
+import AsyncLimiterClass, {
+    AsyncCurrentLimiter,
+} from "https://cdn.skypack.dev/@masx200/async-task-current-limiter?dts";
+import { WalkEntry } from "https://deno.land/[email protected]/fs/_util.ts";
+function searchFilesNames({
+    skip,
+}: // limiter,
+    {
+        skip?: RegExp | RegExp[];
+        // limiter: AsyncCurrentLimiter;
+    }) {
     console.log("type check start!");
+
+    const entry_iter = walk(".", {
+        includeFiles: true,
+        includeDirs: false,
+        exts: ["ts"],
+        skip: [/node_modules/, skip].flat().filter(Boolean) as RegExp[],
+    });
+    return entry_iter;
+}
+if (import.meta.main) {
+    /* deno run -A "check.ts" "--skip=npm|utils" */
+    await start();
+    // .catch(console.error);
+}
+
+async function parallel_check(
+    entry_iter: AsyncIterableIterator<WalkEntry>,
+    limiter: AsyncCurrentLimiter,
+) {
     const stack: string[] = [];
-    for await (
-        const entry of walk(".", {
-            includeFiles: true,
-            includeDirs: false,
-            exts: ["ts"],
-            skip: [/node_modules/, skip].flat().filter(Boolean) as RegExp[],
-        })
-    ) {
+
+    const ps: Array<Promise<void>> = [];
+    for await (const entry of entry_iter) {
         console.log(entry.path);
         if (stack.length < 15) {
             stack.push(entry.path);
         } else {
-            await runDenoCheck([...stack, entry.path]);
+            ps.push(limiter.run(() => runDenoCheck([...stack, entry.path])));
             stack.length = 0;
             // console.log({ status, stdout, stderr });
         }
     }
     if (stack.length) {
-        await runDenoCheck(stack);
+        ps.push(limiter.run(() => runDenoCheck(stack)));
     }
-}
-if (import.meta.main) {
-    /* deno run -A "check.ts" "--skip=npm|utils" */
-    await start();
-    // .catch(console.error);
+    await Promise.all(ps);
 }
 
 async function start() {
+    const limiter = new AsyncLimiterClass(navigator.hardwareConcurrency);
     const args = parse(Deno.args);
     console.log(args);
     const skip = typeof args.skip === "string"
         ? new RegExp(String(args.skip))
         : Array.isArray(args.skip)
         ? args.skip.map((s) => new RegExp(s))
         : undefined;
-    await printFilesNames({ skip }).then(() => console.log("type check Done!"));
+    const entry_iter = searchFilesNames({ skip });
+    await parallel_check(entry_iter, limiter);
+    console.log("type check Done!");
 }
 
 async function runDenoCheck(stack: string[]) {

deno.json

@@ -9,7 +9,7 @@
         "fmt": " deno fmt --config deno.json",
         "test": "deno test  --parallel --unstable -A --config deno.json",
         "lint": "deno lint --config deno.json",
-        "check": "deno run --unstable -A check.ts"
+        "check": "deno run --unstable -A --config deno.json check.ts "
     },
     "fmt": {
         "options": {