linux 进程池实现

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/wait.h>

#define POOL_SIZE 5

void worker(int task_id) {
    printf("Worker %d processing task %d\n", getpid(), task_id);
    sleep(1); // 模拟任务处理时间
}

int main() {
    pid_t pids[POOL_SIZE];
    int task_id = 0;

    for (int i = 0; i < POOL_SIZE; i++) {
        pids[i] = fork();
        if (pids[i] == 0) { // 子进程
            while (1) {
                worker(task_id++);
                sleep(1); // 等待新的任务
            }
        } else if (pids[i] < 0) {
            perror("fork");
            exit(1);
        }
    }

    for (int i = 0; i < POOL_SIZE; i++) {
        waitpid(pids[i], NULL, 0); // 等待所有子进程结束
    }

    return 0;
}