Function runWorker

worker/model-worker.ts:172–194

()

}

async function runWorker() {
  while (running) {
    const currentStatus = Atomics.load(view, 0);
    
    if (currentStatus & 0b100) {
      running = false;
      break;
    }
    
    if ((currentStatus & 0b001) && !processing) {
      processing = true;
      
      await processRequestAsync();
      
    } else if (!processing) {
      Atomics.wait(view, 0, currentStatus);
    }
    
    await new Promise(resolve => setTimeout(resolve, 1));
  }
  
  log('info', '[Worker] Exiting');
}

runWorker().then(() => {
  process.exit(0);