>У меня Пять процессов. Один родительский и четыре дочерних.
>так вот после того как они отработают, каждый из них имеет свое
>значение в одной переменной. моя задача их сложить. я решил, что
>правильно будет блокировать процессы оставяляя один. и так вычислить правильное значение. Только у меня дочерних процессов 5, а так подходит.
там макросы - их можно выкинуть.
сложение в главном модуле легко приделать ;-))
/* Демонстрация запуска нескольких процессов
создадим двунаправленный канал и попробуем
через него дочерние процессы передадут в родительский некие данные
а он их попытается прочитать и распечатать.
*/
#include "defs.h"
typedef struct ps_my {
int pid;
int val;
bool IsExit;
} ps_my_stru;
typedef struct pipe_my {
int pid;
int val;
} pipe_my_data;
#define MAX_CHILD 5
void init_psarr(void);
ps_my_stru ps_info[MAX_CHILD];
int pfd[2]; /*дескрипторы файлов pipe*/
void init_psarr(void) {
ps_info[0].val = 10;
ps_info[1].val = 100;
ps_info[2].val = 1000;
ps_info[3].val = 50;
ps_info[4].val = 500;
for(int i = 0; i < MAX_CHILD; i++) {
ps_info[i].IsExit = false;
}
}
void child_work(int ind) {
pipe_my_data d;
d.pid = getpid();
d.val = ps_info[ind].val;
printf("Работает Дочерний процесс PID = %d, ind = %d, val = %d\n", d.pid, ind, d.val);
/*Пишем 1 раз в канал*/
write(pfd[1], &d, sizeof(d));
}
int FindWorked(void) {
for(int i = 0; i < MAX_CHILD; i++) {
if(ps_info[i].IsExit == false)
return 1; /*нашли работающий процесс*/
}
return 0; /*нет работающих процессов*/
}
int MakeClose(int pid) {
for(int i = 0; i < MAX_CHILD; i++) {
if(ps_info[i].pid == pid) {
ps_info[i].IsExit = true; /*пометим процесс как завершенный*/
return i;
}
}
return -1; /*не нашли этот процесс(в принципе прога должна в этом случае зависать)*/
}
int CalculateWork(void) {
int ret = 0;
for(int i = 0; i < MAX_CHILD; i++) {
if(ps_info[i].IsExit == false) {
ret++;
}
}
return ret;
}
void parent_work(void) {
int pid, ind, i;
int CountWork = CalculateWork();
int FailFind = 0;
printf("Породили %d процессов\n", CountWork);
/*Читаем 5 раз из канала и печатем разультат*/
pipe_my_data d;
for(i = 0; i < CountWork; i++) {
read(pfd[0], &d, sizeof(d));
printf("Получили от процесса %d значение = %d\n", d.pid, d.val);
}
printf("Ждем их завершения\n");
do {
pid = waitpid(-1, NULL, 0);
ind = MakeClose(pid);
if(ind >= 0) {
printf("Завершился процесс pid = %d, ind = %d\n", pid, ind);
} else {
printf("Завершился процесс pid = %d, Но его нет в таблице процессов!!!\n", pid);
FailFind++;
}
CountWork--;
if(CountWork < FailFind) {
printf("Не вижу смысла продолжать ждать потомка, возможно их больше нет!\n");
break;
}
} while(FindWorked());
}
void forktest(void) {
init_psarr();
int pid;
int is_child = 0;
printf("Начало теста\n");
ec_neg1( pipe(pfd) )
printf("Открыли канал\n");
int i;
for(i = 0; i < MAX_CHILD; i++) {
switch(pid = fork()) {
case -1: /*Предок ошибка возможно процесс на запустился пометим его как завершившийся!!!*/
ps_info[i].IsExit = true;
case 0: /*Потомок*/
is_child = 1;
break;
default: /*основной процесс*/
ps_info[i].pid = pid;
}
if(is_child) break;
}
if(is_child) {
child_work(i);
} else {
parent_work();
}
/* printf("Возвращенное значение PID = %d\n", pid);*/
return;
EC_CLEANUP_BGN
EC_FLUSH("forktest")
if(is_child == 1)
exit(EXIT_FAILURE);
EC_CLEANUP_END
}
int main(int argc, char *argv[]) {
forktest();
return 0;
}
Вариант для распечатки
Программирование под UNIX (Public)
on 13-Июл-06, 17:56 
