60fbd6d6 |
1 | const { FixedThreadPool } = require('poolifier') |
5c5a1fb7 |
2 | const pool = new FixedThreadPool(15, './multiFunctionWorker.js', { |
cf9aa6c3 |
3 | errorHandler: e => console.error(e), |
53795b86 |
4 | onlineHandler: () => console.info('worker is online') |
cf9aa6c3 |
5 | }) |
106744f7 |
6 | |
583a27ce |
7 | pool |
a86b6df1 |
8 | .execute({ text: 'hello' }, 'fn0') |
53795b86 |
9 | .then(res => console.info(res)) |
583a27ce |
10 | .catch(err => console.error(err)) |
cf9aa6c3 |
11 | pool |
a86b6df1 |
12 | .execute({ text: 'multiple functions' }, 'fn1') |
53795b86 |
13 | .then(res => console.info(res)) |
583a27ce |
14 | .catch(err => console.error(err)) |
106744f7 |
15 | |
979e2251 |
16 | setTimeout(pool.destroy(), 3000) |