Как этот пример с использованием каналов для производителя и потребителя может предотвратить тупик? - PullRequest
Новая
       6

Как этот пример с использованием каналов для производителя и потребителя может предотвратить тупик?

0 голосов
/ 05 мая 2018

Я рассматриваю пример решения проблемы производителя и потребителя с использованием каналов.

И я не понимаю, как это предотвращает состояние гонки. 

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <signal.h>
#include <fcntl.h>
#include <ctype.h>
#include <string.h>
#include <errno.h>
#include <sys/wait.h>


void producer(FILE *pipe_write_end)
{
  int i;
  for(i = 1; i <= 10; i++) {
    fprintf(pipe_write_end, "%d ", i);
  }
  fclose(pipe_write_end);
  exit(0);
}


void consumer(FILE *pipe_read_end)
{
  int n,k;

  while(1) {
    int n = fscanf(pipe_read_end, "%d", &k);
    if(n == 1) printf("consumer: got %d\n", k);
    else break;
  }
  fclose(pipe_read_end);
  exit(0);
}


int main()
{
  pid_t producer_id, consumer_id;
  int pd[2];
  FILE *pipe_write_end, *pipe_read_end;


  pipe(pd);
  pipe_read_end  = fdopen(pd[0], "r");
  pipe_write_end = fdopen(pd[1], "w");


  producer_id = fork();
  if(producer_id == 0) {
      fclose(pipe_read_end);
    producer(pipe_write_end);

  }

  consumer_id = fork();
  if(consumer_id == 0) {
    fclose(pipe_write_end);
    consumer(pipe_read_end);
  }

  fclose(pipe_read_end);
  fclose(pipe_write_end);
  wait(NULL);
  wait(NULL);

  return 0;
}

В настоящее время я думаю, что int n = fscanf(pipe_read_end, "%d", &k); ждет от производителя закрытия файла, но я не понимаю, как.

Если создано 2 дочерних процесса, 1 для использования, 1 для производства - Как это может автоматически просто производить без ошибок?

...