Function work

test/wasm_worker/lock_async_acquire.c:26–59

}

void work() {
  // emscripten_out("work");
  volatile int x = sharedState0;
  volatile int y = sharedState1;
  assert(x == y+1 || y == x+1);

  if (emscripten_current_thread_is_wasm_worker()) {
    ++numTimesWasmWorkerAcquiredLock;
  } else {
    ++numTimesMainThreadAcquiredLock;
  }

  if (x < y) {
    x = y + 1;
    if (emscripten_current_thread_is_wasm_worker()) {
      emscripten_wasm_worker_sleep(/*nsecs=*/(rand()%100000));
    }
    sharedState0 = x;
  } else {
    y = x + 1;
    if (emscripten_current_thread_is_wasm_worker()) {
      emscripten_wasm_worker_sleep(/*nsecs=*/(rand()%100000));
    }
    sharedState1 = y;

    if (y > 100 && numTimesMainThreadAcquiredLock && numTimesWasmWorkerAcquiredLock) {
      if (!testFinished) {
        testFinished = true;
        emscripten_out("test finished");
        emscripten_wasm_worker_post_function_v(EMSCRIPTEN_WASM_WORKER_ID_PARENT, do_exit);
      }
    }
  }
}

void schedule_work(void *userData);