Remove usage of module.exports (#84)
authorShinigami <chrissi92@hotmail.de>
Mon, 8 Feb 2021 21:05:53 +0000 (22:05 +0100)
committerGitHub <noreply@github.com>
Mon, 8 Feb 2021 21:05:53 +0000 (22:05 +0100)
examples/dynamicExample.js
examples/multiFunctionExample.js
examples/multifunctionWorker.js
examples/staticExample.js
examples/yourWorker.js
src/dynamic.ts
src/fixed.ts
src/index.ts
tests/dynamic.test.js
tests/fixed.test.js

index 22379f204bf5a8a504920e06fea498e76f39f728..22b4f19c4b7394c92b1b91b7d8ffad432e810e4c 100644 (file)
@@ -1,4 +1,4 @@
-const DynamicThreadPool = require('../lib/dynamic')
+const { DynamicThreadPool } = require('poolifier')
 let resolved = 0
 let maxReached = 0
 const pool = new DynamicThreadPool(10, 20, './yourWorker.js', {
index 76b6bbfbff95a347c677e81c6587d5df8c1e2da6..d1314aa94149fe7324fda3df0b91e240f9865532 100644 (file)
@@ -1,4 +1,4 @@
-const FixedThreadPool = require('../lib/fixed')
+const { FixedThreadPool } = require('poolifier')
 const pool = new FixedThreadPool(15, './multifunctionWorker.js', {
   errorHandler: e => console.error(e),
   onlineHandler: () => console.log('worker is online')
index f3efb4529e337945ad17e0734ede160c7c7d2cd7..8a1809ac7c25e81e3e9f697ce98a0b5748bd9c6f 100644 (file)
@@ -1,5 +1,5 @@
 'use strict'
-const { ThreadWorker } = require('../lib/workers')
+const { ThreadWorker } = require('poolifier')
 
 function yourFunction (data) {
   if (data.fname === 'fn0') {
index b9f7503fc8a4d656aa069f181c6ebdd679855d89..f125c477e20df4179c78984eb05f56fbb1a342ed 100644 (file)
@@ -1,4 +1,4 @@
-const FixedThreadPool = require('../lib/fixed')
+const { FixedThreadPool } = require('poolifier')
 let resolved = 0
 const pool = new FixedThreadPool(15, './yourWorker.js', {
   errorHandler: e => console.error(e),
index ac3959d121f1fcfa123f1118374a1c4b3d2bcf4f..4597f6485b0073f01854c8285213c5e27ed689fb 100644 (file)
@@ -1,5 +1,5 @@
 'use strict'
-const { ThreadWorker } = require('../lib/workers')
+const { ThreadWorker } = require('poolifier')
 
 function yourFunction (data) {
   for (let i = 0; i <= 1000; i++) {
index 211141ca5535e0a864d22d38c8ee167e0930dc8f..ca6e4849016a44f005843dbc42e781f377ae30bf 100644 (file)
@@ -1,6 +1,7 @@
 /* eslint-disable @typescript-eslint/strict-boolean-expressions */
 
-import FixedThreadPool, {
+import {
+  FixedThreadPool,
   FixedThreadPoolOptions,
   WorkerWithMessageChannel
 } from './fixed'
@@ -20,7 +21,7 @@ export type DynamicThreadPoolOptions = FixedThreadPoolOptions
  * @author [Alessandro Pio Ardizio](https://github.com/pioardi)
  * @since 0.0.1
  */
-export default class DynamicThreadPool<
+export class DynamicThreadPool<
   Data = any,
   Response = any
 > extends FixedThreadPool<Data, Response> {
@@ -77,5 +78,3 @@ export default class DynamicThreadPool<
     }
   }
 }
-
-module.exports = DynamicThreadPool
index 3ca43cdb1e5e13f0033427e153cdfa80025abca0..39ee595408be3c5ddf07d2d2419c1596628bc644 100644 (file)
@@ -38,7 +38,7 @@ export interface FixedThreadPoolOptions {
  * @author [Alessandro Pio Ardizio](https://github.com/pioardi)
  * @since 0.0.1
  */
-export default class FixedThreadPool<Data = any, Response = any> {
+export class FixedThreadPool<Data = any, Response = any> {
   public readonly workers: WorkerWithMessageChannel[] = []
   public nextWorker: number = 0
 
@@ -161,5 +161,3 @@ export default class FixedThreadPool<Data = any, Response = any> {
     return worker
   }
 }
-
-module.exports = FixedThreadPool
index db6960b86af815b03e43460a3cfef9dfc591a3f8..1d7e0b1fcfc5be98992f2cc5113a00b84ed6db12 100644 (file)
@@ -1,5 +1,5 @@
-import DynamicThreadPool from './dynamic'
-import FixedThreadPool from './fixed'
+import { DynamicThreadPool } from './dynamic'
+import { FixedThreadPool } from './fixed'
 import { ThreadWorker } from './workers'
 
 export {
@@ -10,5 +10,3 @@ export {
 export { DynamicThreadPoolOptions } from './dynamic'
 export { ThreadWorkerOptions } from './workers'
 export { FixedThreadPool, DynamicThreadPool, ThreadWorker }
-
-module.exports = { FixedThreadPool, DynamicThreadPool, ThreadWorker }
index 67f5504100841f2a998a4c8f7927324980b62fbf..5b16a361c173a726c5479c4a2da3565882fd53cf 100644 (file)
@@ -1,5 +1,5 @@
 const expect = require('expect')
-const DynamicThreadPool = require('../lib/dynamic')
+const { DynamicThreadPool } = require('../lib/dynamic')
 const min = 1
 const max = 3
 const pool = new DynamicThreadPool(min, max, './tests/workers/testWorker.js', {
index 604ef80c0e0901740eb658576c465c66a3d350d3..12c705cccf6f6d506fbdf0eeaab6a3ee0b2e5bb8 100644 (file)
@@ -1,5 +1,5 @@
 const expect = require('expect')
-const FixedThreadPool = require('../lib/fixed')
+const { FixedThreadPool } = require('../lib/fixed')
 const numThreads = 10
 const pool = new FixedThreadPool(numThreads, './tests/workers/testWorker.js', {
   errorHandler: e => console.error(e),