feat: add deno 2.x.x support

Signed-off-by: Jérôme Benoit <[email protected]>
poolifier · Sep 19, 2024 · 47dfca2 · 47dfca2
1 parent db08acf
commit 47dfca2
Show file tree

Hide file tree

Showing 7 changed files with 75 additions and 83 deletions.
diff --git a/deno.json b/deno.json
@@ -3,9 +3,7 @@
   "version": "0.4.27",
   "exports": "./src/mod.ts",
   "compilerOptions": {
-    "lib": [
-      "deno.worker"
-    ],
+    "lib": ["deno.worker"],
     "strict": true
   },
   "tasks": {
@@ -26,9 +24,7 @@
     "documentation": "deno doc ./src/mod.ts"
   },
   "test": {
-    "include": [
-      "./tests/**/*.test.mjs"
-    ]
+    "include": ["./tests/**/*.test.mjs"]
   },
   "fmt": {
     "semiColons": false,
@@ -42,18 +38,8 @@
     "expect": "npm:expect@^29.7.0"
   },
   "publish": {
-    "include": [
-      "LICENSE",
-      "README.md",
-      "deno.json",
-      "src/**/*.ts"
-    ]
+    "include": ["LICENSE", "README.md", "deno.json", "src/**/*.ts"]
   },
   "lock": false,
-  "exclude": [
-    "./coverage",
-    "./dist/browser",
-    "./dist/esm",
-    "./npm"
-  ]
+  "exclude": ["./coverage", "./dist/browser", "./dist/esm", "./npm"]
 }
diff --git a/src/pools/selection-strategies/fair-share-worker-choice-strategy.ts b/src/pools/selection-strategies/fair-share-worker-choice-strategy.ts
@@ -22,23 +22,24 @@ export class FairShareWorkerChoiceStrategy<
 > extends AbstractWorkerChoiceStrategy<Worker, Data, Response>
   implements IWorkerChoiceStrategy {
   /** @inheritDoc */
-  public readonly taskStatisticsRequirements: TaskStatisticsRequirements = {
-    runTime: {
-      aggregate: true,
-      average: true,
-      median: false,
-    },
-    waitTime: {
-      aggregate: true,
-      average: true,
-      median: false,
-    },
-    elu: {
-      aggregate: true,
-      average: true,
-      median: false,
-    },
-  }
+  public override readonly taskStatisticsRequirements:
+    TaskStatisticsRequirements = {
+      runTime: {
+        aggregate: true,
+        average: true,
+        median: false,
+      },
+      waitTime: {
+        aggregate: true,
+        average: true,
+        median: false,
+      },
+      elu: {
+        aggregate: true,
+        average: true,
+        median: false,
+      },
+    }
 
   /** @inheritDoc */
   public constructor(

diff --git a/src/pools/selection-strategies/interleaved-weighted-round-robin-worker-choice-strategy.ts b/src/pools/selection-strategies/interleaved-weighted-round-robin-worker-choice-strategy.ts
@@ -22,19 +22,20 @@ export class InterleavedWeightedRoundRobinWorkerChoiceStrategy<
 > extends AbstractWorkerChoiceStrategy<Worker, Data, Response>
   implements IWorkerChoiceStrategy {
   /** @inheritDoc */
-  public readonly taskStatisticsRequirements: TaskStatisticsRequirements = {
-    runTime: {
-      aggregate: true,
-      average: true,
-      median: false,
-    },
-    waitTime: {
-      aggregate: true,
-      average: true,
-      median: false,
-    },
-    elu: DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS,
-  }
+  public override readonly taskStatisticsRequirements:
+    TaskStatisticsRequirements = {
+      runTime: {
+        aggregate: true,
+        average: true,
+        median: false,
+      },
+      waitTime: {
+        aggregate: true,
+        average: true,
+        median: false,
+      },
+      elu: DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS,
+    }
 
   /**
    * Round id.
@@ -156,7 +157,9 @@ export class InterleavedWeightedRoundRobinWorkerChoiceStrategy<
   }
 
   /** @inheritDoc */
-  public setOptions(opts: WorkerChoiceStrategyOptions | undefined): void {
+  public override setOptions(
+    opts: WorkerChoiceStrategyOptions | undefined,
+  ): void {
     super.setOptions(opts)
     this.roundWeights = this.getRoundWeights()
   }

diff --git a/src/pools/selection-strategies/least-busy-worker-choice-strategy.ts b/src/pools/selection-strategies/least-busy-worker-choice-strategy.ts
@@ -22,19 +22,20 @@ export class LeastBusyWorkerChoiceStrategy<
 > extends AbstractWorkerChoiceStrategy<Worker, Data, Response>
   implements IWorkerChoiceStrategy {
   /** @inheritDoc */
-  public readonly taskStatisticsRequirements: TaskStatisticsRequirements = {
-    runTime: {
-      aggregate: true,
-      average: false,
-      median: false,
-    },
-    waitTime: {
-      aggregate: true,
-      average: false,
-      median: false,
-    },
-    elu: DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS,
-  }
+  public override readonly taskStatisticsRequirements:
+    TaskStatisticsRequirements = {
+      runTime: {
+        aggregate: true,
+        average: false,
+        median: false,
+      },
+      waitTime: {
+        aggregate: true,
+        average: false,
+        median: false,
+      },
+      elu: DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS,
+    }
 
   /** @inheritDoc */
   public constructor(

diff --git a/src/pools/selection-strategies/weighted-round-robin-worker-choice-strategy.ts b/src/pools/selection-strategies/weighted-round-robin-worker-choice-strategy.ts
@@ -23,19 +23,20 @@ export class WeightedRoundRobinWorkerChoiceStrategy<
 > extends AbstractWorkerChoiceStrategy<Worker, Data, Response>
   implements IWorkerChoiceStrategy {
   /** @inheritDoc */
-  public readonly taskStatisticsRequirements: TaskStatisticsRequirements = {
-    runTime: {
-      aggregate: true,
-      average: true,
-      median: false,
-    },
-    waitTime: {
-      aggregate: true,
-      average: true,
-      median: false,
-    },
-    elu: DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS,
-  }
+  public override readonly taskStatisticsRequirements:
+    TaskStatisticsRequirements = {
+      runTime: {
+        aggregate: true,
+        average: true,
+        median: false,
+      },
+      waitTime: {
+        aggregate: true,
+        average: true,
+        median: false,
+      },
+      elu: DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS,
+    }
 
   /**
    * Worker node virtual task execution time.

diff --git a/src/pools/thread/dynamic.ts b/src/pools/thread/dynamic.ts
@@ -51,12 +51,12 @@ export class DynamicThreadPool<
   }
 
   /** @inheritDoc */
-  protected shallCreateDynamicWorker(): boolean {
+  protected override shallCreateDynamicWorker(): boolean {
     return (!this.full && this.internalBusy()) || this.empty
   }
 
   /** @inheritDoc */
-  protected checkAndEmitDynamicWorkerCreationEvents(): void {
+  protected override checkAndEmitDynamicWorkerCreationEvents(): void {
     if (this.eventTarget != null) {
       if (!this.fullEventEmitted && this.full) {
         this.eventTarget.dispatchEvent(
@@ -71,7 +71,7 @@ export class DynamicThreadPool<
   }
 
   /** @inheritDoc */
-  protected checkAndEmitDynamicWorkerDestructionEvents(): void {
+  protected override checkAndEmitDynamicWorkerDestructionEvents(): void {
     if (this.eventTarget != null) {
       if (this.fullEventEmitted && !this.full) {
         this.eventTarget.dispatchEvent(
@@ -113,17 +113,17 @@ export class DynamicThreadPool<
   }
 
   /** @inheritDoc */
-  protected get type(): PoolType {
+  protected override get type(): PoolType {
     return PoolTypes.dynamic
   }
 
   /** @inheritDoc */
-  protected get backPressure(): boolean {
+  protected override get backPressure(): boolean {
     return this.full && this.internalBackPressure()
   }
 
   /** @inheritDoc */
-  protected get busy(): boolean {
+  protected override get busy(): boolean {
     return this.full && this.internalBusy()
   }
 }
diff --git a/src/worker/thread-worker.ts b/src/worker/thread-worker.ts
@@ -73,7 +73,7 @@ export class ThreadWorker<
   }
 
   /** @inheritDoc */
-  protected handleKillMessage(message: MessageValue<Data>): void {
+  protected override handleKillMessage(message: MessageValue<Data>): void {
     super.handleKillMessage(message)
     this.port?.close()
   }
@@ -94,7 +94,7 @@ export class ThreadWorker<
    * @inheritDoc
    * @override
    */
-  protected handleError(error: Error | string): string {
+  protected override handleError(error: Error | string): string {
     return error as string
   }
 }