repositories / poolifier.git / blame
| 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 | { | |
| 041dc05b | 8 | errorHandler: e => console.error(e), |
| 6961ca9a JB |
9 | onlineHandler: () => console.info('worker is online') |
| 10 | } | |
| 11 | ) | |
| 106744f7 | 12 | |
| 583a27ce | 13 | pool |
| a86b6df1 | 14 | .execute({ text: 'hello' }, 'fn0') |
| 041dc05b JB |
15 | .then(res => console.info(res)) |
| 16 | .catch(err => console.error(err)) | |
| cf9aa6c3 | 17 | pool |
| a86b6df1 | 18 | .execute({ text: 'multiple functions' }, 'fn1') |
| 041dc05b JB |
19 | .then(res => console.info(res)) |
| 20 | .catch(err => console.error(err)) | |
| 106744f7 | 21 | |
| 979e2251 | 22 | setTimeout(pool.destroy(), 3000) |