Function TEST

library/tests/system/concurrency_validation_test.cpp:55–109

}

TEST(ConcurrencyValidation, ParallelInstancesMatchSequentialBaseline)
{
  // A small set of distinct boards in PBN text form.
  // Source: examples/hands.cpp (representative random deals)
  const std::vector<std::string> pbns = {
    "N:QJ6.K652.J85.T98 873.J97.AT764.Q4 K5.T83.KQ9.A7652 AT942.AQ4.32.KJ3",
    "E:QJT5432.T.6.QJ82 .J97543.K7532.94 87.A62.QJT4.AT75 AK96.KQ8.A98.K63",
    "N:73.QJT.AQ54.T752 QT6.876.KJ9.AQ84 5.A95432.7632.K6 AKJ9842.K.T8.J93"
  };

  const size_t N = pbns.size();
  ensure_threads(N);

  // Prepare deals and sequential baselines (single thread / thr 0)
  std::vector<Deal> deals;
  deals.reserve(N);
  for (const auto& s : pbns) {
    deals.emplace_back(make_deal_from_pbn(s.c_str(), /*trump=*/0, /*first=*/0));
  }

  std::vector<FutureTricks> baseline_ft(N);
  std::vector<int> baseline_rc(N, 0);

  {
    SolverContext ctx;
    for (size_t i = 0; i < N; ++i) {
      FutureTricks ft{};
      const int rc = solve_board(ctx, deals[i], /*target=*/0, /*solutions=*/1, /*mode=*/0, &ft);
      baseline_rc[i] = rc;
      baseline_ft[i] = ft; // copy
    }
  }

  // Run in parallel: one thread per board with its own ThreadData/Context
  std::vector<FutureTricks> out_ft(N);
  std::vector<int> out_rc(N, 0);

  std::vector<std::thread> threads;
  threads.reserve(N);
  for (size_t i = 0; i < N; ++i) {
    threads.emplace_back([i, &deals, &out_ft, &out_rc]() {
      SolverContext ctx;
      FutureTricks ft{};
      const int rc = solve_board(ctx, deals[i], /*target=*/0, /*solutions=*/1, /*mode=*/0, &ft);
      out_rc[i] = rc;
      out_ft[i] = ft;
    });
  }
  for (auto& t : threads) t.join();

  for (size_t i = 0; i < N; ++i) {
    EXPECT_EQ(out_rc[i], baseline_rc[i]) << "Return code mismatch for case " << i;
    EXPECT_TRUE(equal_future_tricks(out_ft[i], baseline_ft[i])) << "FutureTricks mismatch for case " << i;
  }
}