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