Commit | Line | Data |
---|---|---|
74750c7f | 1 | async function runPoolifierTest (pool, { tasks, workerData }) { |
ff5e76e1 JB |
2 | return new Promise((resolve, reject) => { |
3 | let executions = 0 | |
292ad316 | 4 | for (let i = 1; i <= tasks; i++) { |
ff5e76e1 JB |
5 | pool |
6 | .execute(workerData) | |
7 | .then(res => { | |
8 | executions++ | |
9 | if (executions === tasks) { | |
10 | return resolve('FINISH') | |
11 | } | |
12 | return null | |
13 | }) | |
14 | .catch(err => console.error(err)) | |
15 | } | |
16 | }) | |
17 | } | |
18 | ||
74750c7f JB |
19 | function generateRandomInteger (max, min = 0) { |
20 | if (min) { | |
21 | return Math.floor(Math.random() * (max - min + 1) + min) | |
22 | } | |
23 | return Math.floor(Math.random() * max + 1) | |
24 | } | |
25 | ||
292ad316 JB |
26 | const LIST_FORMATTER = new Intl.ListFormat('en-US', { |
27 | style: 'long', | |
28 | type: 'conjunction' | |
29 | }) | |
30 | ||
31 | module.exports = { generateRandomInteger, LIST_FORMATTER, runPoolifierTest } |