@fab1o/concurrency

Create simulated jobs for concurrency simulation & testing.

Each job is async, returns a unique Id, and spends a random amount of time between 0 and 9 seconds to finish, which you may configure.

Examples

Check out this example file to see how it works.

Create 100 jobs:

import { createJobs } from '@fab1o/concurrency';

// returns an array of 1000 promises
const jobs = createJobs(100);

Executing jobs

const jobs = createJobs(100);

for (const job of jobs) {
  await job();
}

Erroring out given a frequency rate

If we want every other job to throw an error, we set errorRate option to 0.5 (that is 50%)

const jobs = createJobs(2, { errorRate: 0.5 });

for (const job of jobs) {
  try {
    const id = await job();

    console.log(`Success with job #${id}`);
  } catch(id) {
    console.log(`Error with job #${id}`);
  }
} 

// error
// success