CSAPP Shell Lab 信号竞争解决：3步阻塞SIGCHLD，避免addjob/deletejob冲突

CSAPP Shell Lab 信号竞争解决：3步阻塞SIGCHLD，避免addjob/deletejob冲突

1. Shell Lab并发问题的核心挑战

在实现Unix shell时，进程管理与信号处理的交互会引发一类经典的并发问题：当子进程在父进程执行addjob前终止，父进程可能收到SIGCHLD信号并先执行deletejob，导致最终jobs列表中出现不一致状态。这种addjob与deletejob的竞争条件（race condition）是Shell Lab实验中最需要警惕的陷阱。

典型的问题场景时序如下：

1. 父进程fork子进程后，子进程立即终止并发送SIGCHLD信号
2. 父进程的信号处理器先捕获信号并执行deletejob
3. 随后父进程才执行addjob操作
4. 最终导致已终止的进程仍残留在jobs列表中

这种竞争条件的本质在于信号处理的异步性——内核可能在任意时刻将信号递送给进程。要解决这个问题，我们需要精确控制SIGCHLD信号的接收时机，确保关键操作的原子性。

2. 信号阻塞的三步解决方案

2.1 信号阻塞的基本原理

Unix信号阻塞机制允许进程暂时屏蔽特定信号的接收。通过sigprocmask系统调用，我们可以控制当前被阻塞的信号集。被阻塞的信号会保持pending状态，直到解除阻塞后才被递送。

关键系统调用：

int sigprocmask(int how, const sigset_t *set, sigset_t *oldset);

参数说明：

• how：SIG_BLOCK（添加阻塞）、SIG_UNBLOCK（解除阻塞）或SIG_SETMASK（直接设置）
• set：要修改的信号集
• oldset：保存原先的信号掩码

2.2 三步阻塞实现流程

以下是解决竞争条件的标准实现模式：

sigset_t mask_all, mask_one, prev_one; // 1. 初始化信号集 Sigfillset(&mask_all); // 所有信号 Sigemptyset(&mask_one); // 空信号集 Sigaddset(&mask_one, SIGCHLD); // 仅SIGCHLD // 2. 在fork前阻塞SIGCHLD Sigprocmask(SIG_BLOCK, &mask_one, &prev_one); if ((pid = fork()) == 0) { // 子进程解除阻塞 Sigprocmask(SIG_SETMASK, &prev_one, NULL); // ...执行子进程代码... exit(0); } // 3. 在addjob前后保护临界区 Sigprocmask(SIG_BLOCK, &mask_all, NULL); addjob(jobs, pid, state, cmdline); Sigprocmask(SIG_SETMASK, &mask_one, NULL); // 解除SIGCHLD阻塞 Sigprocmask(SIG_SETMASK, &prev_one, NULL);

2.3 关键操作时序图

父进程 子进程 | | |-- fork() --| | 阻塞SIGCHLD | | |-- 快速终止 | |-- 发送SIGCHLD(被阻塞) |-- addjob() --| | 临界区保护 | |-- 解除SIGCHLD阻塞 --| |-- 处理pending信号 --| |-- deletejob() --|

3. 实现细节与注意事项

3.1 信号处理器的安全实现

正确的SIGCHLD处理器需要处理三种子进程状态变化：

void sigchld_handler(int sig) { int olderrno = errno; sigset_t mask_all, prev; Sigfillset(&mask_all); while ((pid = waitpid(-1, &status, WNOHANG|WUNTRACED)) > 0) { // 保护全局数据结构访问 Sigprocmask(SIG_BLOCK, &mask_all, &prev); if (WIFEXITED(status)) { // 正常退出 deletejob(jobs, pid); } else if (WIFSIGNALED(status)) { // 信号终止 printf("Job [%d] (%d) terminated by signal %d\n", pid2jid(pid), pid, WTERMSIG(status)); deletejob(jobs, pid); } else if (WIFSTOPPED(status)) { // 信号停止 struct job_t *job = getjobpid(jobs, pid); job->state = ST; printf("Job [%d] (%d) stopped by signal %d\n", job->jid, pid, WSTOPSIG(status)); } Sigprocmask(SIG_SETMASK, &prev, NULL); } errno = olderrno; }

3.2 waitfg的正确实现

等待前台作业完成时，应使用sigsuspend而非简单的循环检查，避免CPU空转：

void waitfg(pid_t pid) { sigset_t mask; Sigemptyset(&mask); while (fgpid(jobs) == pid) { sigsuspend(&mask); // 原子性地解除阻塞并等待信号 } }

3.3 进程组管理

为确保信号能正确传递给整个进程组，子进程需要设置新的进程组：

if ((pid = fork()) == 0) { setpgid(0, 0); // 创建新进程组，PGID=子进程PID // ...其余代码... }

在发送信号时使用负PID表示进程组：

kill(-pid, SIGINT); // 发送给整个进程组

4. 测试验证方法

4.1 关键测试场景

4.2 测试对比方法

使用提供的测试工具进行自动化验证：

make test01 # 单独测试trace01 make rtest01 # 参考实现输出 diff -u tsh.out tshref.out

典型输出对比：

- ./myspin 1 & - [1] (15514) ./myspin 1 & + ./myspin 1 & + [1] (15708) ./myspin 1 &

5. 高级优化技巧

5.1 错误处理增强

所有系统调用都应检查返回值并处理错误：

void Sigprocmask(int how, const sigset_t *set, sigset_t *oldset) { if (sigprocmask(how, set, oldset) < 0) unix_error("sigprocmask error"); }

5.2 全局变量访问保护

任何对全局jobs列表的访问都应处于信号阻塞状态：

sigset_t mask_all, prev; Sigfillset(&mask_all); Sigprocmask(SIG_BLOCK, &mask_all, &prev); // 访问jobs列表 Sigprocmask(SIG_SETMASK, &prev, NULL);

5.3 避免内存泄漏

确保所有终止的子进程都被正确回收：

while ((pid = waitpid(-1, &status, WNOHANG|WUNTRACED)) > 0) { // 处理每个终止的子进程 }

6. 总结与经验分享

在实际调试过程中，有几个容易忽视的细节值得特别注意：

1. 信号堆栈：某些平台对信号处理器的调用会使用特殊堆栈，大缓冲区可能导致栈溢出
2. errno保存：信号处理器中修改的errno可能影响主程序逻辑
3. 系统调用重启：被信号中断的系统调用可能需要特殊处理

一个实用的调试技巧是添加详细的日志输出：

void eval(char *cmdline) { if (verbose) { printf("eval: parsing '%s'\n", cmdline); } // ... }

通过系统性地应用信号阻塞技术，我们能够构建出健壮的shell实现，正确处理各种并发场景。这种模式不仅适用于Shell Lab，也是Unix系统编程中处理异步事件的重要范式。