+6

examples/atomics/increment.ts

reviewed

··· 1 1 + import { mo } from '../../src/index.ts'; 2 2 + import type { AtomicInt32 } from '../../src/index.ts'; 3 3 + 4 4 + export const increment = mo(import.meta, (counter: AtomicInt32): number => { 5 5 + return counter.add(1); 6 6 + });

+19

examples/atomics/main.ts

reviewed

··· 1 1 + // Shared memory between main thread and workers using AtomicInt32. 2 2 + // 3 3 + // Run: node --experimental-strip-types examples/atomics/main.ts 4 4 + 5 5 + import { workerPool, AtomicInt32 } from '../../src/index.ts'; 6 6 + import { increment } from './increment.ts'; 7 7 + 8 8 + const counter = new AtomicInt32(); 9 9 + const pool = workerPool(4); 10 10 + 11 11 + // Fire off 100 increments across 4 workers 12 12 + await Promise.all( 13 13 + Array.from({ length: 100 }, () => pool(increment(counter))), 14 14 + ); 15 15 + 16 16 + pool[Symbol.dispose](); 17 17 + 18 18 + console.log(`Expected: 100`); 19 19 + console.log(`Actual: ${counter.load()}`);