SharedArrayBuffer와 Atomics: 공유 메모리와 동기화

const sab = new SharedArrayBuffer(4); // 공유 메모리
const view = new Int32Array(sab);

view[0] = 42;
// worker.postMessage({ sab }) 후, Worker에서도:
// view[0] === 42 , 복사나 전달 없이!

Cross-Origin-Opener-Policy: same-origin
Cross-Origin-Embedder-Policy: require-corp

if (crossOriginIsolated) {
  // SharedArrayBuffer 사용 가능
  const sab = new SharedArrayBuffer(4);
} else {
  console.warn('교차 출처 격리가 필요합니다');
}

// Worker A와 Worker B가 동시에 실행
const local = view[0];  // 읽기
view[0] = local + 1;   // 쓰기, 원자적이지 않음!

const sab = new SharedArrayBuffer(4);
const view = new Int32Array(sab);

// 원자적 증가, 이전 값을 반환
const oldValue = Atomics.add(view, 0, 1);

// 기타 산술 연산
Atomics.sub(view, 0, 1);          // 빼기
Atomics.and(view, 0, 0b1111);     // 비트 AND
Atomics.or(view, 0, 0b0001);      // 비트 OR
Atomics.xor(view, 0, 0b1010);     // 비트 XOR

// 원자적 읽기
const val = Atomics.load(view, 0);

// 원자적 쓰기
Atomics.store(view, 0, 42);

// 원자적 교환, 새 값을 쓰고 이전 값을 반환
const prev = Atomics.exchange(view, 0, 100);

// expectedValue와 현재 값이 같을 때만 쓰기
const old = Atomics.compareExchange(
  view, 0,
  /* expected  */ 5,
  /* replacement */ 10
);
// old === 5이면 성공 → view[0] === 10
// old !== 5이면 실패 → view[0] 변경 없음

// worker.js, view[0]가 0인 동안 대기 (블로킹)
const result = Atomics.wait(view, 0, 0);
// result: "ok" | "not-equal" | "timed-out"

// main.js (또는 다른 worker), 대기 중인 스레드 깨우기
Atomics.store(view, 0, 1);
Atomics.notify(view, 0, 1); // 최대 1개 스레드 깨우기

// 메인 스레드에서도 사용 가능, 비블로킹
const { async, value } = Atomics.waitAsync(view, 0, 0);
if (async) {
  value.then((result) => console.log('깨어남:', result));
}

// main.js
const sab = new SharedArrayBuffer(8);
const ctrl = new Int32Array(sab);
// ctrl[0]: 다음 작업 인덱스 (공유 카운터)
// ctrl[1]: 완료된 작업 수

const TOTAL = 1000;
const workers = Array.from({ length: 4 }, () =>
  new Worker(new URL('./worker.js', import.meta.url))
);
workers.forEach(w => w.postMessage({ sab, total: TOTAL }));

// worker.js
self.onmessage = ({ data: { sab, total } }) => {
  const ctrl = new Int32Array(sab);
  while (true) {
    // 원자적으로 다음 작업 번호를 가져옴
    const idx = Atomics.add(ctrl, 0, 1);
    if (idx >= total) break;
    processTask(idx);
    Atomics.add(ctrl, 1, 1); // 완료 카운터
  }
};