docs: private void initQueues()
    {
      LOGGER.debug("Init Queues");
      if (_active.getAndSet(true))
      {
        // NOP if the loader is already active
        return;
      }
      // start PUT and PROCESS queues
      _queuePut = new ArrayBlockingQueue<>(48);
      _queueProcess = new ArrayBlockingQueue<>(48);
      _put = new PutQueue(this);
      _process = new ProcessQueue(this);
  
      // Start queue. NOTE: This is not actively used
      _queueData = new ArrayBlockingQueue<>(1024);
      _thread = new Thread(this);
      _thread.setName("StreamLoaderThread");
      _thread.start();
  
      // Create stage
      _stage = new BufferStage(this, _op, _csvFileBucketSize, _csvFileSize);
    }