在xv6中实现Priority Round Robin时遭遇内核启动停滞问题求助

问题描述 #

在xv6中实现优先级轮转（Priority Round Robin）调度器时，已修复锁相关的panic错误，但内核启动后停滞，仅显示“xv6 kernel is booting”及hart启动信息后停止，且hart启动顺序偶尔变化。

提供的代码 #

调度器实现 #

scheduler(void)
{
  struct proc *p;
  struct cpu *c = mycpu();
  struct proc *highp = 0;
  
  c->proc = 0;
  for(;;){
    // Avoid deadlock by ensuring that devices can interrupt.
    intr_on();

    for(p = proc; p < &proc[NPROC]; p++) {
      if (p->state != RUNNABLE)
      continue;
      if (highp == 0 || p->priority > highp->priority)
      highp = p;
      if (highp != 0) {
        continue;
      }
      }

      if (ticks-lastagingtime > 100) {
        struct proc *p;
        for (p = proc ; p < &proc[NPROC]; p++) {
          if (p->state == SLEEPING || p->state == RUNNABLE)
          p->priority++;
        }
        lastagingtime = ticks;

      }
     
    }
  }

setpriority实现 #

setpriority(int pid, int priority)
{
  struct  proc *p;
  for (p = proc; p < &proc[NPROC]; p++) {
    if (p->pid == pid) {
       p->priority = priority;
    }
  }
    return pid;
}

核心问题与修复建议 #

1. 缺失进程切换逻辑（最致命） #

当前调度器仅遍历找到最高优先级的highp进程，但完全没有执行进程切换的代码。原xv6调度器中的proc_run(highp)是核心，没有它CPU会一直空循环，永远不会启动任何用户进程或内核进程，直接导致启动停滞。

2. 进程表遍历未加锁 #

你提到已添加自旋锁，但代码中看不到acquire(&ptable.lock)和release(&ptable.lock)操作。多hart场景下，不加锁遍历进程表会导致竞态条件，进程状态读取错误，进而引发停滞或行为异常（比如hart启动顺序变化）。

3. highp未循环重置 #

每次调度循环开始时，highp没有重置为0，会保留上一次的进程指针，导致永远只调度同一个进程（如果它持续RUNNABLE），或出现野指针问题。

4. 优先级老化逻辑位置错误且未加锁 #

老化逻辑放在进程遍历之后，且未加锁，会导致多CPU下的竞态，同时老化逻辑没有和调度循环正确联动，无法按时生效。

5. setpriority函数的缺陷 #

• 遍历进程表未加锁，存在竞态；
• 未处理pid不存在的情况，返回值无法体现修改是否成功；
• 未过滤僵尸进程（ZOMBIE状态），修改无效进程的优先级无意义；
• 修改优先级后未触发调度，若当前运行的进程优先级被降低，无法及时切换到更高优先级进程。

修正后的代码示例 #

调度器修正版 #

scheduler(void)
{
  struct proc *p;
  struct cpu *c = mycpu();
  struct proc *highp;
  
  c->proc = 0;
  for(;;){
    // 开中断，避免死锁
    intr_on();

    // 每次循环重置最高优先级进程指针
    highp = 0;

    // 加锁遍历进程表，寻找最高优先级可运行进程
    acquire(&ptable.lock);
    for(p = proc; p < &proc[NPROC]; p++) {
      if (p->state != RUNNABLE)
        continue;
      if (highp == 0 || p->priority > highp->priority)
        highp = p;
    }
    release(&ptable.lock);

    // 加锁执行优先级老化
    acquire(&ptable.lock);
    if (ticks - lastagingtime > 100) {
      for (p = proc ; p < &proc[NPROC]; p++) {
        if (p->state == SLEEPING || p->state == RUNNABLE)
          p->priority++;
      }
      lastagingtime = ticks;
    }
    release(&ptable.lock);

    // 找到可运行进程则切换执行，否则进入空闲等待
    if (highp != 0) {
      proc_run(highp);
    } else {
      intr_off();
      asm volatile("wfi"); // 等待中断，减少空循环消耗
    }
  }
}

setpriority修正版 #

setpriority(int pid, int priority)
{
  struct proc *p;
  int found = 0;

  acquire(&ptable.lock);
  for (p = proc; p < &proc[NPROC]; p++) {
    // 仅对非僵尸进程修改优先级
    if (p->pid == pid && p->state != ZOMBIE) {
       p->priority = priority;
       found = 1;
       break; // 找到后立即退出循环，避免无效遍历
    }
  }
  release(&ptable.lock);

  // 若修改的是当前运行进程的优先级，主动触发调度
  if (found && myproc() != NULL && myproc()->pid == pid) {
    yield();
  }

  // 返回-1表示未找到对应进程，返回pid表示修改成功
  return found ? pid : -1;
}

内容的提问来源于stack exchange，提问作者Ayxux