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