c - C 中奇怪的 fork() 问题

标签 c mapreduce operating-system fork

这是对基本 mapReduce 的赋值,它查找文本文件中字符串的出现次数。

我有一个只调用 spawnMapper() 的 main。

问题是 fork() == 0 但它不会进入该部分并打印“我成功了!”或其他任何东西。如果我将 int pid 设置为 fork 返回的内容,或者如果我直接使用 fork,就会出现这种情况。

请帮忙,它可以编译但无法正常工作,我很困惑。

#include <stddef.h>
#include <string.h>
#include <unistd.h>
#include <stdlib.h>
#include <stdio.h>
#include "reducer.h"

//parent = greater than 1 child = 0

char fpeek(FILE *file);

void spawnMapper(char* keyword, char* fileLocation, int numberMappers){

    FILE *fptr;

    if((fptr=fopen(fileLocation, "r")) == NULL){
        printf("ERROR! opening file");
        exit(1);
    }

    fseek(fptr, 0L, SEEK_END);
    int size = ftell(fptr);

    int mapperSize = size/numberMappers;
    fseek(fptr, 0L, SEEK_SET);

    int i;
    for(i = 0; i < numberMappers; i++){

        fptr = fopen(fileLocation, "r");
        int pToC[2]; //pipe parent to child
        int cToP[2]; //pipe child to parent
        if(pipe(pToC) == -1 || pipe(cToP) == -1){
            printf("pipe failure");
            exit(1);
        }

        if (fork() ==  0) {
            printf("I made it!");
            fptr = fopen(fileLocation,"r");
            int threadSize = 0;
            int found = 0;
            while(fpeek(fptr) != EOF && threadSize < mapperSize){
                fseek(fptr, i*mapperSize, SEEK_SET);
                char* stringCheck;
                fscanf(fptr, "%s", stringCheck);                
                if(strcmp(keyword, stringCheck) == 0){
                    found += 1;
                }
                threadSize += strlen(stringCheck);
            }
            printf("found %d", found);
            //pipes to parent how many found 
        }
        else{

        }
    }
    fclose(fptr);   

}

char fpeek(FILE *stream){
    char c;

    c = fgetc(stream);
    ungetc(c, stream);

    return c;
}

最佳答案

Kaylum 在评论中指出 printf 是行缓冲的。这是一个普遍的误解。 stdin 是行缓冲的;其他功能(例如 putchar)也受到影响。尽管如此,他的解决方案是正确的:打印一个换行符以强制立即打印整行。

或者,fflush(stdout); 将立即打印文本, 不需要换行符。

在我看来,Mike 的建议似乎行不通,因为在您的程序运行之前,潜在的问题就与 termios 相关;终端处于熟化/规范模式(意味着 termios 将在发送所有数据之前等到换行符,以便它可以代表应用程序处理诸如退格之类的事情)。如果您想将终端设置为原始模式,这意味着一旦按下键就会将字符发送到您的程序,这与 C 无关,但您可能需要阅读 this pagethis page ...

关于c - C 中奇怪的 fork() 问题,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/33771437/

相关文章:

c - 当指针指向一个新字符串时,分配给该指针寻址的字符串的内存会发生什么?

java - 在 Map Reduce 作业中使用多线程

c - 对正在写入的文件调用 stat() 的结果是什么?

c - 什么是好的多核 64 位 "Hello World"程序?

java - 如何查找两个数字是否是格雷码序列中的连续数字

c++ - 如何访问和分配结构上的 int 指针数据类型的值?

spring batch Hadoop 失败并出现 org.springframework.beans.factory.BeanNotOfRequiredTypeException

hadoop - Hadoop-示例jar中包含的示例无法在伪分布式模式下完成

c# - 我的程序如何确定它是在 32 位还是 64 位 Windows 上运行?

Java:通过 Runtime.getRuntime().exec() 转义操作系统相关调用的字符串的正确方法