Commit | Line | Data |
---|---|---|
aee46736 | 1 | const { FixedThreadPool, PoolEvents } = require('poolifier') |
c2dbbe2b | 2 | let resolved = 0 |
164d950a | 3 | let poolBusy = 0 |
cf9aa6c3 | 4 | const pool = new FixedThreadPool(15, './yourWorker.js', { |
5 | errorHandler: e => console.error(e), | |
6 | onlineHandler: () => console.log('worker is online') | |
7 | }) | |
aee46736 | 8 | pool.emitter.on(PoolEvents.busy, () => poolBusy++) |
3e460d6d | 9 | |
15e5141f | 10 | const start = performance.now() |
bf962cba | 11 | const iterations = 1000 |
292ad316 | 12 | for (let i = 1; i <= iterations; i++) { |
583a27ce JB |
13 | pool |
14 | .execute({}) | |
7a6a0a96 | 15 | .then(() => { |
583a27ce JB |
16 | resolved++ |
17 | if (resolved === iterations) { | |
15e5141f | 18 | console.log('Time taken is ' + (performance.now() - start)) |
164d950a | 19 | return console.log('The pool was busy for ' + poolBusy + ' times') |
583a27ce JB |
20 | } |
21 | return null | |
22 | }) | |
23 | .catch(err => console.error(err)) | |
6dc67cda | 24 | } |