task = (i, state) =>
new Promise(async (resolve, reject) => {
state.c++;
await Promises.delay(50);
const c = state.c; // measure concurrency in the middle of the task’s run
await Promises.delay(50 + 50 * Math.random());
state.c--;
resolve(c);
})
{
const state = { c: 0 };
const results = await Promise.all(
Array.from({ length: 20 }, (_, i) => task(i, state))
);
return results;
}
{
const state = { c: 0 };
const queue = new PQueue({ concurrency: 4 });
return queue.addAll(
Array.from({ length: 20 }, (_, i) => i).map(i => () => task(i, state))
);
}
PQueue = (await require("https://bundle.run/p-queue")).default
Purpose-built for displays of data
Observable is your go-to platform for exploring data and creating expressive data visualizations. Use reactive JavaScript notebooks for prototyping and a collaborative canvas for visual data exploration and dashboard creation.
