()
| 69 | |
| 70 | // just a helper for this demo |
| 71 | async function tryShutdown() { |
| 72 | if (jobsToComplete === 0) { |
| 73 | await new Promise((resolve) => { |
| 74 | setTimeout(resolve, 500); |
| 75 | }); |
| 76 | await worker.end(); |
| 77 | process.exit(); |
| 78 | } |
| 79 | } |
| 80 | |
| 81 | // ///////////////// |
| 82 | // START A WORKER // |