继续从同一个父进程创建多个子进程

Question

我正在尝试使用单独的进程计算当前目录中每个二进制文件的校验和以提高性能。但是，出于某种原因，我的输出总是出乎意料。

如何为每个文件创建一个单独的进程？我应该在 while(pids[i] != -1) 内完成整个分叉过程吗？

file_cnt = number of .bin files in the current dir

pid_t pids[file_cnt];

for(i = 0; i < file_cnt; i++) 
{
    if((pids[i]=fork()) < 0)
    {
        printf("Error forking");
        return 0;
    }
    else if(pids[i]==0)
    {
        printf("Entering child \n");
        printf("%s ", filenames[i]);

        //reading file
        handle = open( filenames[i], O_RDONLY );

        //allocating memory
        buffer = malloc( BUFFER_SIZE );

        checksum = 0;

        do
        {
            //calculating checksum
        } while( length );

        printf( " -%d\n", checksum);
        printf("Exiting child \n");
    }
}

我的目录中有三个文件，我的输出结果如下：

There are 3 files:
Entering child 
whateve2.bin  -10540
Exiting child 
Entering child 
Entering child 
whatever.bin  -8399
Exiting child 
whatever3.bin  -34871
Exiting child 
Entering child 
whatever.bin  -8399
Exiting child 
vab@Vaibhav:~/CS330$ Entering child 
whatever3.bin  -34871
Exiting child 
Entering child 
whatever3.bin  -34871
Exiting child 
Entering child 
whatever3.bin  -34871
Exiting child

Answer 1

您不会在每个孩子的 else 块末尾调用 exit()。因此，孩子将跳回for 循环并执行下一次迭代，再次调用fork()。如果有3个文件，则parent会fork 3次，file 1的child会fork 2次，file 2的child会fork 1次。

在调用printf("Exiting child \n"); 之后，您需要调用exit(0) 以便子进程退出。

针对您的评论，您调用fork() 并检查返回值不

请记住，如果成功，fork() 会返回两次：一次使用子进程的 pid 向父级返回，一次使用 0 向子级返回。

Answer 2

正如其他人所说，您不是 exit()ing 在 else 块的末尾。

但是我想提出一个改进建议：由于您正在尝试实现并行处理以提高快速任务的性能，那么使用线程而不是 fork()ing 整个进程怎么样？

这是一个代码示例，说明了您可以做什么：

// adapted from https://computing.llnl.gov/tutorials/pthreads/
// compile with: gcc calc_checksum.c -o calc_checksum -lpthread

#include <pthread.h>
#include <stdio.h>

void* calc_checksum(void* pFileNameIdx)
{
    const int fileNameIdx = (int)pFileNameIdx;
    printf("Entering child \n");
    // filenames should be a global variable somewhere
    // or, better, just pass "&filenames[fileNameIdx]" instead of pFileNameIdx
    printf("%s ", filenames[fileNameIdx]);

    // reading file
    handle = open(filenames[fileNameIdx], O_RDONLY);

    // allocating memory
    buffer = malloc(BUFFER_SIZE);

    int checksum = 0;

    do
    {
        // calculating checksum
    } while(length);

    printf( " -%d\n", checksum);
    printf("Exiting child \n");

    free(buffer);  // !! don't forget to free() the resources that you don't need anymore

    // exit the thread
    pthread_exit(NULL);
}

int main (int argc, char *argv[])
{
    // initialization code ...
    file_cnt = number of .bin files in the current dir

    pthread_t threads[file_cnt];
    int retCode;

    for(i = 0; i < file_cnt; i++) 
    {
        retCode = pthread_create(&threads[i], NULL, calc_checksum, (void*)i);
        if (retCode){
            printf("ERROR; return code from pthread_create() is %d\n", retCode);
            exit(-1);
        }
    }

    pthread_exit(NULL);
}

注意：无论使用哪种方法（fork() 或 pthreads）：不要忘记 free() 使用 malloc() 保留的内存。