Offload functions to worker threads with shared memory primitives for Node.js.
refactor: rename AtomicX classes to XAtomic for naming consistency
Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
+115
-115
+2
-2
examples/atomics/increment.ts
+2
-2
examples/atomics/increment.ts
···
1
1
import { mo } from '../../src/index.ts';
2
-
import type { AtomicInt32 } from '../../src/index.ts';
2
+
import type { Int32Atomic } from '../../src/index.ts';
3
3
4
-
export const increment = mo(import.meta, (counter: AtomicInt32): number => {
4
+
export const increment = mo(import.meta, (counter: Int32Atomic): number => {
5
5
return counter.add(1);
6
6
});
+9
-9
src/index.ts
+9
-9
src/index.ts
···
39
39
Int64,
40
40
Uint64,
41
41
Bool,
42
-
AtomicInt8,
43
-
AtomicUint8,
44
-
AtomicInt16,
45
-
AtomicUint16,
46
-
AtomicInt32,
47
-
AtomicUint32,
48
-
AtomicInt64,
49
-
AtomicUint64,
50
-
AtomicBool,
42
+
Int8Atomic,
43
+
Uint8Atomic,
44
+
Int16Atomic,
45
+
Uint16Atomic,
46
+
Int32Atomic,
47
+
Uint32Atomic,
48
+
Int64Atomic,
49
+
Uint64Atomic,
50
+
BoolAtomic,
51
51
Mutex,
52
52
MutexGuard,
53
53
RwLock,
+4
-4
test/fixtures/sync.ts
+4
-4
test/fixtures/sync.ts
···
1
1
import { mo } from 'moroutine';
2
-
import type { AtomicInt32, Mutex, RwLock } from 'moroutine';
2
+
import type { Int32Atomic, Mutex, RwLock } from 'moroutine';
3
3
4
-
export const atomicAdd = mo(import.meta, (counter: AtomicInt32, value: number): number => {
4
+
export const atomicAdd = mo(import.meta, (counter: Int32Atomic, value: number): number => {
5
5
return counter.add(value);
6
6
});
7
7
8
8
export const mutexIncrement = mo(
9
9
import.meta,
10
-
async (mutex: Mutex, counter: AtomicInt32, times: number): Promise<void> => {
10
+
async (mutex: Mutex, counter: Int32Atomic, times: number): Promise<void> => {
11
11
for (let i = 0; i < times; i++) {
12
12
const guard = await mutex.lock();
13
13
const val = counter.load();
···
17
17
},
18
18
);
19
19
20
-
export const rwlockRead = mo(import.meta, async (rwlock: RwLock, counter: AtomicInt32): Promise<number> => {
20
+
export const rwlockRead = mo(import.meta, async (rwlock: RwLock, counter: Int32Atomic): Promise<number> => {
21
21
const guard = await rwlock.readLock();
22
22
const val = counter.load();
23
23
rwlock.readUnlock();