Simple-XX
diff --git a/‎.github/workflows/workflow.yml‎
Lines changed: 9 additions & 3 deletions b/‎.github/workflows/workflow.yml‎
Lines changed: 9 additions & 3 deletions
diff --git a/‎src/arch/aarch64/link.ld‎
Lines changed: 3 additions & 5 deletions b/‎src/arch/aarch64/link.ld‎
Lines changed: 3 additions & 5 deletions
diff --git a/‎src/arch/riscv64/link.ld‎
Lines changed: 2 additions & 4 deletions b/‎src/arch/riscv64/link.ld‎
Lines changed: 2 additions & 4 deletions
diff --git a/‎src/task/AGENTS.md‎
Lines changed: 1 addition & 1 deletion b/‎src/task/AGENTS.md‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎src/task/task_manager.cpp‎
Lines changed: 76 additions & 2 deletions b/‎src/task/task_manager.cpp‎
Lines changed: 76 additions & 2 deletions
diff --git a/‎src/task/tick_update.cpp‎
Lines changed: 4 additions & 0 deletions b/‎src/task/tick_update.cpp‎
Lines changed: 4 additions & 0 deletions
diff --git a/‎tests/integration_test/aarch64_minimal/main.cpp‎
Lines changed: 1 addition & 1 deletion b/‎tests/integration_test/aarch64_minimal/main.cpp‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎tests/system_test/CMakeLists.txt‎
Lines changed: 1 addition & 0 deletions b/‎tests/system_test/CMakeLists.txt‎
Lines changed: 1 addition & 0 deletions
@@ -32,7 +32,9 @@ jobs:
           fetch-depth: 1
 
       - name: Shallow submodule init
-        run: git submodule update --init --recursive --depth 1
+        run: |
+          git config --global --add safe.directory '*'
+          git submodule update --init --recursive --depth 1
 
       - name: Cache CMake build (riscv64)
         uses: actions/cache@v4
@@ -51,7 +53,9 @@ jobs:
         run: |
           for i in $(seq 1 $SYSTEM_TEST_RUNS); do
             echo "=== riscv64 System Test Run $i/$SYSTEM_TEST_RUNS ==="
-            if ! timeout 300 cmake --build build_riscv64 --target system_test_run; then
+            timeout 300 cmake --build build_riscv64 --target system_test_run > /tmp/st_out_$i.txt 2>&1 || true
+            cat /tmp/st_out_$i.txt
+            if ! grep -q "Failed: 0" /tmp/st_out_$i.txt; then
               echo "riscv64 system test run $i/$SYSTEM_TEST_RUNS FAILED"
               exit 1
             fi
@@ -80,7 +84,9 @@ jobs:
           fetch-depth: 1
 
       - name: Shallow submodule init
-        run: git submodule update --init --recursive --depth 1
+        run: |
+          git config --global --add safe.directory '*'
+          git submodule update --init --recursive --depth 1
 
       - name: Cache CMake build (aarch64)
         uses: actions/cache@v4
 
@@ -168,11 +168,9 @@ SECTIONS
    *(.dynbss)
    *(.bss .bss.* .gnu.linkonce.b.*)
    *(COMMON)
-   /* Align here to ensure that the .bss section occupies space up to
-      _end.  Align after .bss to ensure correct alignment even if the
-      .bss section disappears because there are no input sections.
-      FIXME: Why do we need it? When there is no .bss section, we do not
-      pad the .data section.  */
+    /* Align here to ensure that the .bss section occupies space up to
+       _end.  Align after .bss to ensure correct alignment even if the
+       .bss section disappears because there are no input sections.  */
    . = ALIGN(. != 0 ? 64 / 8 : 1);
   }
   _bss_end__ = .; __bss_end__ = .;
 
@@ -178,10 +178,8 @@ SECTIONS {
         *(.bss .bss.* .gnu.linkonce.b.*)
         *(COMMON)
         /* Align here to ensure that the .bss section occupies space up to
-          _end.  Align after .bss to ensure correct alignment even if the
-          .bss section disappears because there are no input sections.
-          FIXME: Why do we need it? When there is no .bss section, we do not
-          pad the .data section.  */
+           _end.  Align after .bss to ensure correct alignment even if the
+           .bss section disappears because there are no input sections.  */
         . = ALIGN(. != 0 ? 64 / 8 : 1);
     }
     . = ALIGN(64 / 8);
 
@@ -41,7 +41,7 @@ mutex.cpp                  # Mutex implementation (uses SpinLock internally)
 - Schedulers own their internal run queues — TaskManager dispatches to per-policy schedulers
 - `TaskManagerSingleton::instance()` (defined in `task_manager.hpp`) is the global entry point
 - TCB contains arch-specific context pointer — populated by `switch.S`
-- TODO in `task_manager.cpp`: task stealing across cores (not yet implemented)
+- `Balance()` in `task_manager.cpp`: cross-core work-stealing (steals kNormal tasks from most-loaded core, called every 64 ticks)
 
 ## ANTI-PATTERNS
 - **DO NOT** call Schedule() before TaskManager initialization in boot sequence
 
@@ -179,8 +179,82 @@ auto TaskManager::FindTask(Pid pid) -> TaskControlBlock* {
 }
 
 auto TaskManager::Balance() -> void {
-  // 算法留空
-  // TODO: 检查其他核心的运行队列长度，如果比当前核心长，则窃取任务
+  auto current_core = cpu_io::GetCurrentCoreId();
+  auto& current_sched = cpu_schedulers_[current_core];
+
+  // 获取当前核心 kNormal 队列长度（无锁快速检查）
+  size_t current_load = 0;
+  if (current_sched.schedulers[static_cast<uint8_t>(SchedPolicy::kNormal)]) {
+    current_load =
+        current_sched.schedulers[static_cast<uint8_t>(SchedPolicy::kNormal)]
+            ->GetQueueSize();
+  }
+
+  // 寻找负载最高的核心
+  size_t max_load = 0;
+  size_t max_core = current_core;
+
+  for (size_t core_id = 0; core_id < SIMPLEKERNEL_MAX_CORE_COUNT; ++core_id) {
+    if (core_id == current_core) {
+      continue;
+    }
+    auto& other_sched = cpu_schedulers_[core_id];
+    if (other_sched.schedulers[static_cast<uint8_t>(SchedPolicy::kNormal)]) {
+      size_t load =
+          other_sched.schedulers[static_cast<uint8_t>(SchedPolicy::kNormal)]
+              ->GetQueueSize();
+      if (load > max_load) {
+        max_load = load;
+        max_core = core_id;
+      }
+    }
+  }
+
+  // 仅当差值 > 1 时才窃取（避免 ping-pong）
+  if (max_core == current_core || max_load <= current_load + 1) {
+    return;
+  }
+
+  // 按核心 ID 顺序获取锁，防止死锁
+  auto& source_sched = cpu_schedulers_[max_core];
+  size_t first_core = (current_core < max_core) ? current_core : max_core;
+  size_t second_core = (current_core < max_core) ? max_core : current_core;
+
+  LockGuard<SpinLock> lock_first(cpu_schedulers_[first_core].lock);
+  LockGuard<SpinLock> lock_second(cpu_schedulers_[second_core].lock);
+
+  // 重新检查（持锁后条件可能已变化）
+  auto* source_scheduler =
+      source_sched.schedulers[static_cast<uint8_t>(SchedPolicy::kNormal)].get();
+  auto* dest_scheduler =
+      current_sched.schedulers[static_cast<uint8_t>(SchedPolicy::kNormal)]
+          .get();
+
+  if (!source_scheduler || !dest_scheduler) {
+    return;
+  }
+
+  size_t source_load = source_scheduler->GetQueueSize();
+  size_t dest_load = dest_scheduler->GetQueueSize();
+
+  if (source_load <= dest_load + 1) {
+    return;
+  }
+
+  auto* stolen = source_scheduler->PickNext();
+  if (!stolen) {
+    return;
+  }
+
+  if (stolen->aux && stolen->aux->cpu_affinity.value() != UINT64_MAX &&
+      !(stolen->aux->cpu_affinity.value() & (1UL << current_core))) {
+    source_scheduler->Enqueue(stolen);
+    return;
+  }
+
+  dest_scheduler->Enqueue(stolen);
+  klog::Debug("Balance: Stole task '{}' (pid={}) from core {} to core {}",
+              stolen->name, stolen->pid, max_core, current_core);
 }
 
 auto TaskManager::ReapTask(TaskControlBlock* task) -> void {
 
@@ -67,6 +67,10 @@ auto TaskManager::TickUpdate() -> void {
     }
   }
 
+  if (cpu_sched.scheduler_started && (cpu_sched.local_tick % 64) == 0) {
+    Balance();
+  }
+
   if (need_preempt && cpu_sched.scheduler_started) {
     Schedule();
   }
 
@@ -1,6 +1,6 @@
 /**
  * @copyright Copyright The SimpleKernel Contributors
- * @brief TODO: Add description
+ * @brief AArch64 minimal boot test
  */
 
 #include <cstdarg>
 
@@ -34,6 +34,7 @@ ADD_EXECUTABLE (
     tick_test.cpp
     zombie_reap_test.cpp
     stress_test.cpp
+    balance_test.cpp
     ${CMAKE_SOURCE_DIR}/src/syscall.cpp
     ${CMAKE_SOURCE_DIR}/src/io_buffer.cpp)
Original file line number	Diff line number	Diff line change
`@@ -67,6 +67,10 @@ auto TaskManager::TickUpdate() -> void {`
`67`	`67`	`}`
`68`	`68`	`}`
`69`	`69`
	`70`	`+ if (cpu_sched.scheduler_started && (cpu_sched.local_tick % 64) == 0) {`
	`71`	`+ Balance();`
	`72`	`+ }`
	`73`	`+`
`70`	`74`	`if (need_preempt && cpu_sched.scheduler_started) {`
`71`	`75`	`Schedule();`
`72`	`76`	`}`