Published
Edited
Sep 13, 2021
3 stars
import {worker} from "@fil/worker"
C = navigator.hardwareConcurrency || 4
runWorkers = {
launchWorkers;
const seed = Math.random(),
time = performance.now();
await Promise.all(
Array.from(
{ length: C },
(_, start) =>
new Promise(notify =>
worker(compute, { seed, sharedBuffer, start, n: 1000, C })(notify)
)
)
);
return performance.now() - time;
}
(runWorkers, new Float32Array(sharedBuffer))
function compute(options) {
const sharedArray = new Float32Array(options.sharedBuffer),
n = options.n || 1000,
C = navigator.hardwareConcurrency || 4;
for (let i = options.start; i < sharedArray.length; i += C) {
for (
let a = 0;
a < n;
a++ // make it slow :D
)
sharedArray[i] = Math.cos(i / 100 + options.seed);
}
return "anything"; // a message saying we're done
}
normal = {
if (!launchNormal) return;
const seed = Math.random(),
time = performance.now();
for (let start = 0; start < C; start++)
compute({ seed, sharedBuffer, start, n: 1000, C });
return performance.now() - time;
}
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.
