17
18 int main(int argc, char *argv[])
19 {
20
21 int Pid,Status,Size;
22 double Value;
25 mkfifo('/tmp/channel.l»,FMode) ;
26 mkfifo (' / tmp/channel. 2», FMode) ;
28 vector<double> X(100,13.0);
29 vector<double> Y;
30 ofstream OPipe('/tmp/channel.l»,ios::app);
31 ifstream IPipe('/tmp/channel.2»);
32 OPipe << X.size() « endl;
33 ostream_iterator<double> Optr(OPipe,'
»);
34 copy(X.begin(),X.end(),Optr);
35 OPipe « flush;
36 IPipe » Size;
37 for (int N = 0;N < Size; N++)
38 {
39 IPipe » Value;
40 Y.push_back(Value);
41 }
42
43 IPipe.close();
44 OPipe.close();
45 unlink('/tmp/channel.1»);
46 unlink('/tmp/channel.2»);
47 cout « accumulate(Y.begin(),Y.end(),-13.0) « endl;
48
49 return(0);
50 }
В программе 11.3.1 используется две FIFO-структуры. Вспомните, что FIFO-структуры являются однонаправленными компонентами. Поэтому, если процессы должны обмениваться данными, то необходимо использовать по крайней мере две FIFO-структуры. В программе 11.3.1 они называются channel.1 и channel.2. Обратите внимание на установку флагов полномочий для FIFO- структур (строка 16). Эти полномочия означают, что владелец FIFO-структуры имеет право доступа для чтения и записи, а все остальные — право доступа только для чтения. При выполнении строки 30 FIFO- структура channel.1 будет открыта только для вывода данных. Тот же результат можно было бы получить следующим образом
Используемые здесь параметры алгоритма open () означают, что FIFO-структура будет открыта в режиме дозаписи. В программе 11.3.1 алгоритм copy () используется для вставки объектов в объект OPipe типа fstream и косвенно в FIFO-структуру. Мы могли бы также использовать здесь объект типа
fstream:fstreamOPipe('/tmp/channel.l», ios::out | ios::app);
В этом случае взаимодействие процессов было бы ограничено выводом данных только в режиме дозаписи. Если бы мы не использовали флаг ios: :app , попытка объекта типа ofstream создать FIFO-сгруктуру (см. строку 30) была бы неудачной.
К сожалению, такой вариант работать не будет. Создание FIFO-структур находится в компетенции функции mkfifo(). В строках 45 и 46 программы 11.3.1 FIFO-структуры удаляются из файловой систе
Профиль программы 11.3.1
Имя программы program11-3a.cc
Описание Для пересылки контейнерного объекта через FIFO-структуру используются объекты ТИпа ostream_iterator и ofstream. Для извлечения информации из FIFO-структуры применяется объект типа ifstream.
Требуемые заголовки
<unistd.h>, <iomanip>, <algorithm>, <fstream.h>,<vector>,<iterator> <strstream.h>, <stdlib.h>, <sys/wait.h>, <sys/types.h>, <sys/stat.h> <fcntl.h>, <numeric>.
Инструкции по компиляции и компоновке программ
с++ -о program11-3a program113a.сс
Среда для тестирования
SuSE Linux 7.1, gcc 2.95.2, Solaris 8, Sun Workshop 6.
Инструкции по выполнению
./program11-3a & program11-3b
Примечания
Сначала запускается программа 11.3.1. Программа11.3.2 содержит инструкцию sleep, которая восполняет собой отсутствие реальной синхронизации.
Программа 11.3.2 считывает данные из FIFO-структуры channel. 1 и записывает информацию в FIFO- структуру channel. 2.
// Программа 11.3.2. Считывание данных из FIFO-структуры
// channel.l и запись информации в
// FIFO-структурУ channel.2
10 using namespace std; 11
12 class multiplier{
13 double X,-
14 public:
15 multiplier(double Value) { X = Value;}
16 double &operator()(double Y) { X = (X * Y);return(X);}
17 }; 18
19
20 int main(int argc,char *argv[])
21 { 22
23 double Size;
24 double Data;
25 vector<double> X;
