repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
perf: pin volta node version for benchmarking
[poolifier.git]
/
examples
/
dynamicExample.js
diff --git
a/examples/dynamicExample.js
b/examples/dynamicExample.js
index 79f73c11c53b0f296cd077ecca35fc53a18cab1c..1b7391d759b01c7d6a41dbc0a953bfc33e5f2c8b 100644
(file)
--- a/
examples/dynamicExample.js
+++ b/
examples/dynamicExample.js
@@
-1,4
+1,4
@@
-const { DynamicThreadPool } = require('poolifier')
+const { DynamicThreadPool
, PoolEvents
} = require('poolifier')
let resolved = 0
let poolFull = 0
let poolBusy = 0
let resolved = 0
let poolFull = 0
let poolBusy = 0
@@
-6,10
+6,10
@@
const pool = new DynamicThreadPool(10, 20, './yourWorker.js', {
errorHandler: e => console.error(e),
onlineHandler: () => console.log('worker is online')
})
errorHandler: e => console.error(e),
onlineHandler: () => console.log('worker is online')
})
-pool.emitter.on(
'full'
, () => poolFull++)
-pool.emitter.on(
'busy'
, () => poolBusy++)
+pool.emitter.on(
PoolEvents.full
, () => poolFull++)
+pool.emitter.on(
PoolEvents.busy
, () => poolBusy++)
-const start =
Dat
e.now()
+const start =
performanc
e.now()
const iterations = 1000
for (let i = 1; i <= iterations; i++) {
pool
const iterations = 1000
for (let i = 1; i <= iterations; i++) {
pool
@@
-17,7
+17,7
@@
for (let i = 1; i <= iterations; i++) {
.then(() => {
resolved++
if (resolved === iterations) {
.then(() => {
resolved++
if (resolved === iterations) {
- console.log('Time taken is ' + (
Dat
e.now() - start))
+ console.log('Time taken is ' + (
performanc
e.now() - start))
console.log('The pool was full for ' + poolFull + ' times')
return console.log('The pool was busy for ' + poolBusy + ' times')
}
console.log('The pool was full for ' + poolFull + ' times')
return console.log('The pool was busy for ' + poolBusy + ' times')
}