Function test_thread_group_dynamic

tests/system_test/thread_group_test.cpp:123–176

* @brief 测试线程组的动态加入和离开 */

 * @brief 测试线程组的动态加入和离开
 */
void test_thread_group_dynamic(void* /*arg*/) {
  klog::Info("=== Thread Group Dynamic Test ===");

  auto leader_holder = kstd::make_unique<TaskControlBlock>("DynamicLeader", 10,
                                                           nullptr, nullptr);
  auto* leader = leader_holder.get();
  leader->pid = g_local_pid_counter.fetch_add(1);
  leader->aux->tgid = leader->pid;

  constexpr int kThreadCount = 5;
  etl::unique_ptr<TaskControlBlock> thread_holders[kThreadCount];
  TaskControlBlock* threads[kThreadCount];

  for (int i = 0; i < kThreadCount; ++i) {
    thread_holders[i] = kstd::make_unique<TaskControlBlock>("DynamicThread", 10,
                                                            nullptr, nullptr);
    threads[i] = thread_holders[i].get();
    threads[i]->pid = g_local_pid_counter.fetch_add(1);
  }

  // 动态加入
  klog::Info("Joining threads...");
  for (int i = 0; i < kThreadCount; ++i) {
    threads[i]->JoinThreadGroup(leader);
    size_t size = leader->GetThreadGroupSize();
    klog::Debug("After join {}: group size={}", i, size);
  }

  size_t final_size = leader->GetThreadGroupSize();
  klog::Info("Final group size: {} (expected {})", final_size,
             kThreadCount + 1);

  klog::Info("Leaving threads...");
  for (int i = 0; i < kThreadCount; ++i) {
    threads[i]->LeaveThreadGroup();
    size_t size = leader->GetThreadGroupSize();
    klog::Debug("After leave {}: group size={}", i, size);
  }

  size_t remaining_size = leader->GetThreadGroupSize();
  klog::Info("Remaining group size: {} (expected 1)", remaining_size);

  bool passed = (final_size == static_cast<size_t>(kThreadCount + 1) &&
                 remaining_size == 1);
  if (passed) {
    klog::Info("Thread Group Dynamic Test: PASS");
  } else {
    klog::Err("Thread Group Dynamic Test: FAIL");
    g_tests_failed++;
  }

  g_tests_completed++;
  sys_exit(0);
}

/**
 * @brief 测试线程组成员同时退出