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