Adding a changelog file , removing other library dev dependencies and bench, add... v1.0.0
authoraardizio <alessandroardizio94@gmail.com>
Fri, 24 Jan 2020 18:58:23 +0000 (19:58 +0100)
committeraardizio <alessandroardizio94@gmail.com>
Fri, 24 Jan 2020 18:58:23 +0000 (19:58 +0100)
.gitignore
.npmignore [new file with mode: 0644]
CHANGELOG.md [new file with mode: 0644]
benchmarks/bench.js
package.json

index 2ac23b4dcd7693112a53537111e23655dcb1603f..6c68f3af62ef20a3d0c24af183c5652f2f4b1595 100644 (file)
@@ -41,5 +41,6 @@ jspm_packages
 
 # Mac
 .DS_Store/
+.DS_Store
 
 .history/
\ No newline at end of file
diff --git a/.npmignore b/.npmignore
new file mode 100644 (file)
index 0000000..e9ee244
--- /dev/null
@@ -0,0 +1,4 @@
+.github
+benchmarks
+examples
+tests
\ No newline at end of file
diff --git a/CHANGELOG.md b/CHANGELOG.md
new file mode 100644 (file)
index 0000000..f9ffd37
--- /dev/null
@@ -0,0 +1,14 @@
+# Changelog
+
+All notable changes to this project will be documented in this file.
+
+The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
+and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
+
+## [1.0.0] - 2020-24-01
+
+### Added
+
+- FixedThreadPool implementation
+- DynamicThreadPool implementation
+- WorkerThread implementation to improve developer experience
\ No newline at end of file
index d7b2f1a36c322f29b5745bcd527ccd159113a903..0dde5055f466161ca6c9863ddb2ed4b4436b8859 100644 (file)
@@ -2,12 +2,10 @@ const Benchmark = require('benchmark')
 const suite = new Benchmark.Suite()
 const FixedThreadPool = require('../lib/fixed')
 const DynamicThreadPool = require('../lib/dynamic')
-const Pool = require('worker-threads-pool')
 const size = 30
 const tasks = 1
 
 // pools
-const externalPool = new Pool({ max: size })
 const fixedPool = new FixedThreadPool(size,
   './yourWorker.js', { maxTasks: 10000 })
 const dynamicPool = new DynamicThreadPool(size / 2, size * 3, './yourWorker.js', { maxTasks: 10000 })
@@ -47,30 +45,6 @@ async function dynamicTest () {
   })
 }
 
-async function externalPoolTest () {
-  return new Promise((resolve, reject) => {
-    let executions = 0
-    for (let i = 0; i <= tasks; i++) {
-      new Promise((resolve, reject) => {
-        externalPool.acquire('./externalWorker.js', { workerData: workerData }, (err, worker) => {
-          if (err) {
-            return reject(err)
-          }
-          worker.on('error', reject)
-          worker.on('message', res => {
-            executions++
-            resolve(res)
-          })
-        })
-      }).then(res => {
-        if (tasks === executions) {
-          resolve('FINISH')
-        }
-      })
-    }
-  })
-}
-
 async function test () {
   // add tests
   suite.add('PioardiStaticPool', async function () {
@@ -79,9 +53,6 @@ async function test () {
     .add('PioardiDynamicPool', async function () {
       await dynamicTest()
     })
-    .add('ExternalPool', async function () {
-      await externalPoolTest()
-    })
   // add listeners
     .on('cycle', function (event) {
       console.log(String(event.target))
index 88d328a201847f7894a338abb431326cac6cc6b0..e8d7e795ad8b3987817c6aaccf997a0d773d6490 100644 (file)
@@ -1,6 +1,6 @@
 {
   "name": "poolifier",
-  "version": "0.0.2",
+  "version": "1.0.0",
   "description": "Library on top of node js worker threads that implement various worker pools type",
   "main": "index.js",
   "scripts": {
@@ -44,8 +44,7 @@
     "mocha": "^7.0.0",
     "mocha-lcov-reporter": "^1.3.0",
     "nyc": "^15.0.0",
-    "standard": "^14.3.1",
-    "worker-threads-pool": "^2.0.0"
+    "standard": "^14.3.1"
   },
   "engines": {
     "node": ">=12.0.0"