Method run

tools/core/bench.cc:444–476

  }

  void run(core_interface::Index::Pointer index,
           core_interface::BaseIndexQueryParam::Pointer query_param,
           int max_iter, int topk) {
    // Check
    if (batch_sparse_counts_.size() == 0) {
      return;
    }

    query_param_ = query_param;
    query_param_->topk = topk;
    query_param_->is_linear = false;

    // Do bench
    signal(SIGINT, stop);
    bench_result_.mark_start();
    auto start_time = Monotime::MilliSeconds();
    for (size_t i = 0; i < threads_; ++i) {
      pool_->execute(this, &SparseBench<T>::start_bench, index, max_iter,
                     &STOP_NOW);
    }

    while (!pool_->is_finished()) {
      this_thread::sleep_for(chrono::milliseconds(1));
      if (Monotime::MilliSeconds() - start_time > bench_secs_ * 1000) {
        STOP_NOW = true;
      }
    }

    pool_->wait_finish();

    bench_result_.mark_end();
    bench_result_.print();
  }

  void set_tag_lists(const std::vector<std::vector<uint64_t>> &id_to_tags_list,
                     const std::vector<uint64_t> &tag_key_list) {