Class default

Runs a list of tasks one with the configured concurrency. When maxConcurrentTask is set to 1 this class behaves like a task queue. You can obtain info about tasks by listening to the events exposed by this class. See the events property for more information.

Example

In this example we simulate fetching 30 different people from an API. We simulated random fetching time that, by running the example, will result in out-of-order fetching.

const log = LoggerManager.getLogger("examples.task-runner-simple");

let personGenerated = 0;
const genPerson = (): Person => {
    const personNo = ++personGenerated;
    return {
        name: `John ${personNo}`,
        surname: `Doe ${personNo}`,
        email: `jdoe${personNo}@mailinator.com`,
        username: `john${personNo}`
    };
};

const tr = new TaskRunner();
tr.events.taskCompleted.addListener(() => log.debug(`${people.length} people fetched so far`));
tr.waitForCompletion().then(() => log.debug("Execution complete"));

const people: Person[] = [];
for (let i = 0; i < 30; i++) {
    tr.submitTask(async () => {
        await delay(Math.round(Math.random() * 10));
        const p = genPerson();
        people.push(p);
    });
}
Copy