Merge pull request #14 from Edujugon/dev

Update code examples
Edujugon · May 8, 2023 · c158d41 · c158d41
2 parents bef3afb + 40e2521
commit c158d41
Show file tree

Hide file tree

Showing 7 changed files with 206 additions and 19 deletions.
diff --git a/examples/basic/package-lock.json b/examples/basic/package-lock.json
diff --git a/examples/basic/package.json b/examples/basic/package.json
@@ -12,6 +12,6 @@
   "license": "ISC",
   "dependencies": {
     "axios": "^1.4.0",
-    "node-parallelizer": "^2.1.1"
+    "node-parallelizer": "^3.0.0"
   }
 }
diff --git a/examples/basic/src/lambda-parallelizer.js b/examples/basic/src/lambda-parallelizer.js
@@ -3,17 +3,21 @@ const { Parallelizer, PARALLELIZER_CHILD, PARALLELIZER_THREADS } = require("node
 const parallelizerType = process.env.PARALLELIZER_TYPE || PARALLELIZER_CHILD;
 const parallelizerDebug = process.env.PARALLELIZER_DEBUG_MODE_ENABLED === 'true' ? true : false;
 
-const parallelizer = new Parallelizer({ type: parallelizerType, debug: parallelizerDebug, parallelizationPerCPU: process.env.PROCESSESPERCPU || 1 });
+const parallelizer = new Parallelizer({
+  type: parallelizerType,
+  debug: parallelizerDebug,
+  parallelizationPerCPU: process.env.PROCESSESPERCPU || 1,
+  filePath: "/var/task/src/parallelizer-code.js",
+  processBatchFunctionName: 'batchProcessor'
+});
 
-// Creates child processes based with your custom code.
-parallelizer.parallelizerFunction({filePath: "/var/task/src/parallelizer-code.js", processBatchFunctionName: 'batchProcessor' });
 
 exports.handler = async (event) => {
 
   const batch = [...Array(event.number).keys()];
 
   // Run batch in parallel
-  const responses = await parallelizer.runBatch(batch);
+  const responses = await parallelizer.run(batch);
 
   console.log(JSON.stringify(responses));
 };
diff --git a/examples/with-bundler/package-lock.json b/examples/with-bundler/package-lock.json
diff --git a/examples/with-bundler/package.json b/examples/with-bundler/package.json
@@ -13,7 +13,7 @@
   "dependencies": {
     "axios": "^1.4.0",
     "esbuild": "^0.17.18",
-    "node-parallelizer": "^2.1.1"
+    "node-parallelizer": "^3.0.0"
   },
   "devDependencies": {
     "serverless-esbuild": "^1.43.0",

diff --git a/examples/with-bundler/src/lambda-parallelizer.js b/examples/with-bundler/src/lambda-parallelizer.js
@@ -3,17 +3,20 @@ const { Parallelizer, PARALLELIZER_CHILD, PARALLELIZER_THREADS } = require("node
 const parallelizerType = process.env.PARALLELIZER_TYPE || PARALLELIZER_CHILD;
 const parallelizerDebug = process.env.PARALLELIZER_DEBUG_MODE_ENABLED === 'true' ? true : false;
 
-const parallelizer = new Parallelizer({ type: parallelizerType, debug: parallelizerDebug, parallelizationPerCPU: process.env.PROCESSESPERCPU || 1 });
-
-// Creates child processes based with your custom code.
-parallelizer.parallelizerFunction({filePath: "/var/task/src/parallelizer-code-min.js", processBatchFunctionName: 'batchProcessor' });
+const parallelizer = new Parallelizer({
+  type: parallelizerType,
+  debug: parallelizerDebug,
+  parallelizationPerCPU: process.env.PROCESSESPERCPU || 1,
+  filePath: "/var/task/src/parallelizer-code-min.js",
+  processBatchFunctionName: 'batchProcessor'
+});
 
 exports.handler = async (event) => {
 
   const batch = [...Array(event.number).keys()];
 
   // Run batch in parallel
-  const responses = await parallelizer.runBatch(batch);
+  const responses = await parallelizer.run(batch);
 
   console.log(JSON.stringify(responses));
 };
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "node-parallelizer",
-  "version": "3.0.0",
+  "version": "3.0.1",
   "description": "A NodeJS package for running code in parallel. Initially created to provide multiprocessing in an AWS Lambda function, but it can be used in any NodeJS environment.",
   "main": "src/index.js",
   "scripts": {