Method worker_loop

src/pybind/docling_threaded_parser.h:30–128

  };

  inline void docling_threaded_parser::worker_loop()
  {
    using clock_type = std::chrono::steady_clock;

    while(true)
      {
        std::pair<std::string, int> task;
        {
          std::lock_guard<std::mutex> lock(task_mutex);

          if(task_queue.empty())
            {
              break;
            }

          task = task_queue.front();
          task_queue.pop();
        }

        const std::string& doc_key = task.first;
        int page_number = task.second;

        page_decode_result result;
        result.doc_key = doc_key;
        result.page_number = page_number;

        try
          {
            auto itr = key2doc.find(doc_key);
            if(itr == key2doc.end())
              {
                result.success = false;
                result.error_message = "Document key not found: " + doc_key;
              }
            else
              {
                auto& doc_decoder = itr->second;

                auto total_start = clock_type::now();

                auto stage_start = clock_type::now();
                auto page_decoder = doc_decoder->make_thread_safe_page_decoder(
                  page_number,
                  config.keep_qpdf_warnings);
                result.timings.make_page_decoder_s
                  = std::chrono::duration<double>(clock_type::now() - stage_start).count();

                stage_start = clock_type::now();
                page_decoder->decode_page(config);
                result.timings.decode_page_s
                  = std::chrono::duration<double>(clock_type::now() - stage_start).count();

                if(config.create_word_cells)
                  {
                    stage_start = clock_type::now();
                    page_decoder->create_word_cells(config);
                    result.timings.create_word_cells_s
                      = std::chrono::duration<double>(clock_type::now() - stage_start).count();