Something went wrong. Try again.
Offload functions to worker threads with shared memory primitives for Node.js.
Something went wrong. Try again.
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556import { registerSync } from './reconstruct.ts';
export class Int64Atomic { static readonly byteSize = 8; static readonly byteAlignment = 8; private readonly view: BigInt64Array;
constructor(buffer?: SharedArrayBuffer, byteOffset?: number) { const buf = buffer ?? new SharedArrayBuffer(8); const offset = byteOffset ?? 0; this.view = new BigInt64Array(buf, offset, 1); }
load(): bigint { return Atomics.load(this.view, 0); }
store(value: bigint): void { Atomics.store(this.view, 0, value); }
add(value: bigint): bigint { return Atomics.add(this.view, 0, value); }
sub(value: bigint): bigint { return Atomics.sub(this.view, 0, value); }
and(value: bigint): bigint { return Atomics.and(this.view, 0, value); }
or(value: bigint): bigint { return Atomics.or(this.view, 0, value); }
xor(value: bigint): bigint { return Atomics.xor(this.view, 0, value); }
exchange(value: bigint): bigint { return Atomics.exchange(this.view, 0, value); }
compareExchange(expected: bigint, replacement: bigint): bigint { return Atomics.compareExchange(this.view, 0, expected, replacement); }
[Symbol.for('moroutine.shared')](): { tag: string; buffer: SharedArrayBuffer; byteOffset: number } { return { tag: 'Int64Atomic', buffer: this.view.buffer as SharedArrayBuffer, byteOffset: this.view.byteOffset }; }}
registerSync('Int64Atomic', Int64Atomic);