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