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