Function processNext

scan-worker.js:252–282

()

      });
    }
  };

  // Use a simple queue system
  const queue = [{ type: 'dir', path: directoryPath }];
  const seenDirs = new Set();
  let activeOps = 0;

  // Promise to signal completion
  let resolveDone;
  const donePromise = new Promise(resolve => { resolveDone = resolve; });

  const processNext = () => {
    // If no active ops and queue is empty, we are done
    if (activeOps === 0 && queue.length === 0) {
      if (traversedFileEntries > 0) {
        parentPort.postMessage({
          type: 'progress',
          processed: traversedFileEntries
        });
      }
      resolveDone({ files, totalFiles: traversedFileEntries });
      return;
    }

    // While we have capacity and items in queue, start processing
    while (activeOps < MAX_CONCURRENT_OPS && queue.length > 0) {
      const item = queue.shift();
      activeOps++;

      if (item.type === 'dir') {
        processDirectory(item.path).finally(() => {
          activeOps--;
          processNext();
        });