fix duplicate proc

117 · Jan 16, 2025 · e9675ff · e9675ff
1 parent 73df4cd
commit e9675ff
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 3 deletions.
diff --git a/deno.json b/deno.json
@@ -1,7 +1,7 @@
 {
   "name": "@117/interrupt",
   "description": "Task queue for interrupt handling.",
-  "version": "2.0.3",
+  "version": "2.0.4",
   "exports": "./mod.ts",
   "imports": {
     "@/": "./",

diff --git a/src/onInterrupt.ts b/src/onInterrupt.ts
@@ -1,5 +1,8 @@
 /** @module interrupt */
 
+/** Represents whether the task queue is being processed. */
+let isExecuting = false;
+
 /**
  * Represents a task to be executed with an optional error handler.
  * @interface
@@ -69,8 +72,15 @@ const processTasks = async (): Promise<void> => {
  * @async
  * @returns {Promise<void>}
  */
-const onBeforeInterrupt = async (): Promise<void> =>
-  await processTasks().then(() => Deno.exit());
+const onBeforeInterrupt = async (): Promise<void> => {
+  if (isExecuting) {
+    return;
+  }
+
+  isExecuting = true;
+  await processTasks();
+  Deno.exit();
+};
 
 /** Registers the interrupt handlers for SIGINT and SIGTERM signals. */
 Deno.addSignalListener("SIGINT", onBeforeInterrupt);