基于fork()与wait()实现多进程文件拷贝的-j选项问题咨询

你的核心问题是错误地在每次fork后立即调用wait()，这会导致父进程阻塞等待刚创建的子进程完成，完全失去并行拷贝的效果。要实现-j选项的并行控制，需要先填满进程池（最多j-1个拷贝子进程），之后通过监听子进程退出事件动态补充新进程，直到所有文件处理完毕。

正确逻辑流程 #

1. 初始化当前活跃子进程数为0，设定最大并行拷贝进程数为max_workers = j - 1（因为协调进程本身算1个，总进程数不超过j）
2. 遍历所有待拷贝文件：
   • 若当前活跃子进程数 < max_workers，直接fork新的拷贝子进程，活跃数+1
   • 若当前活跃子进程数 >= max_workers，调用wait()等待任意子进程结束，活跃数-1后再fork新进程，活跃数+1
3. 所有文件分配完毕后，循环调用wait()等待剩余所有子进程结束

修正后的伪代码 #

// PSEUDO CODE
int max_workers = j - 1; // j是传入的-j参数值，需≥2
int active_workers = 0;
int nbFiles = 待拷贝文件总数;
int current_file = 0;

while (current_file < nbFiles) {
    // 进程池已满时，等待一个子进程退出释放槽位
    if (active_workers >= max_workers) {
        wait(&status);
        active_workers--;
    }

    pid_t pid = fork();
    if (pid == -1) {
        perror("erreur de fork");
        exit(1);
    } else if (pid == 0) {
        // 子进程：执行当前文件的拷贝任务
        copy_file(文件列表[current_file], 目标路径);
        exit(0); // 子进程完成后必须退出，避免继承父进程循环逻辑
    } else {
        // 父进程：更新活跃进程数与当前文件索引
        active_workers++;
        current_file++;
    }
}

// 等待所有剩余活跃子进程结束
while (active_workers > 0) {
    wait(&status);
    active_workers--;
}

关键细节说明 #

• wait()的调用时机：仅当活跃子进程数达到上限时调用wait()释放槽位；所有文件分配完成后，必须等待剩余子进程全部结束，避免父进程提前退出。
• 子进程必须exit：子进程完成拷贝后立即退出，否则会继承父进程的循环逻辑，导致无限制创建子进程。
• max_workers的计算：-j N要求总进程数为N（1个协调进程+N-1个拷贝进程），因此最大并行拷贝数为N-1。

以你的示例./prog -j 3 t/a/a t/a/b t/a/c t/b为例：

1. max_workers=2，先创建2个子进程处理t/a/a和t/a/b，active_workers=2
2. 进程池已满，父进程wait()等待任意子进程结束
3. 假设t/a/a的拷贝子进程先结束，active_workers变为1，父进程立即fork新子进程处理t/a/c，active_workers回到2
4. 所有文件分配完毕，父进程wait()等待剩余2个子进程结束，最终所有任务完成

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