Function test_mutex_contention

tests/system_test/mutex_test.cpp:169–213

}

void test_mutex_contention(void* /*arg*/) {
  klog::Info("=== Mutex Contention Test ===");

  Mutex mtx("contention_test");
  std::atomic<int> counter{0};
  bool passed = true;

  ContentionArgs ctx_a;
  ctx_a.mtx = &mtx;
  ctx_a.counter = &counter;

  ContentionArgs ctx_b;
  ctx_b.mtx = &mtx;
  ctx_b.counter = &counter;

  auto task_a = kstd::make_unique<TaskControlBlock>(
      "ContentionA", 10, contention_worker, reinterpret_cast<void*>(&ctx_a));
  auto task_b = kstd::make_unique<TaskControlBlock>(
      "ContentionB", 10, contention_worker, reinterpret_cast<void*>(&ctx_b));

  TaskManagerSingleton::instance().AddTask(std::move(task_a));
  TaskManagerSingleton::instance().AddTask(std::move(task_b));

  int timeout = 100;
  while (timeout > 0 && counter.load() < 10) {
    (void)sys_sleep(50);
    timeout--;
  }

  if (counter.load() != 10) {
    klog::Err("test_mutex_contention: FAIL — counter={}, expected 10",
              counter.load());
    passed = false;
  }

  if (passed) {
    klog::Info("Mutex Contention Test: PASSED");
  } else {
    klog::Err("Mutex Contention Test: FAILED");
    g_tests_failed++;
  }

  g_tests_completed++;
  sys_exit(0);
}

// =========================================================================
// test_mutex_ordering