$selector->add(«CMD ERR, .CMD OUT);

while (@ready = $selector->can read) { foreach $fh (@ready) {

if (fileno($fh) == fileno(CMD ERR))

{print STDERR: , scalar <CMD ERR>}

else

{print STDOUT: , scalar <CMD OUT>} $selector->remove($fh) if eof($fh);

close(CMD GUT); close(CMD ERR);

Мы отправляем короткую входную строку, а затем закрываем манипулятор. Тем самым предотвращается ситуация взаимной блокировки двух процессов, каждый из которых ожидает записи данных другим процессом.

1> Смотри также-

Документация по стандартным модулям IO::Select; 1РС::0реп2 и 1РС::0репЗ; описание функции alarm вperifunc(i); рецепты 16.8; 16.15-16.16.

16.10. Взаимодействие между родственными процессами

Проблема

Имеются два взаимосвязанных процесса, которые должны обмениваться данными. Вам требуется более высокая степень контроля по сравнению с той, что обеспечивают open, system и . . . .

Решение

Воспользуйтесь pipe, а затем - fork:

pipe(READER, WRITER); if (fork) {

tt Выполнить родительский код, в котором происходит либо чтение,

# либо запись (что-то одно), } else {

# Выполнить код потомка, в котором происходит либо чтение,

# либо запись (что-то одно),

Либо используйте особую форму open:

if (Spid = open(CHILD, !-)) {

# Выполнить родительский код, передающий данные потомку

} else {

die cannot fork $ unless defined $pid,

# Иначе выполнить код потомка, принимающий данные от родителя

Или по-другому:

If ($pid = open(CHILD, -I )) {

# Выполнить родительский код, принимающий данные от потомка } else {

die cannot fork $i unless defined $pid

# Иначе выполнить код потомка, передающий данные родителю

Комментарий

Канал представляет собой два файловых манипулятора, связанных так, что записанные в один файловый манипулятор данные могут быть прочитаны из другого. Функция pipe создает два манипулятора, связанных в канал; первый (приемник) предназначен для чтения, а второй (передатчик) - для записи Хотя вы не сможете взять два существующих манипулятора и объединить их в канал, функция pipe часто используется при обмене данными между процессами. Один процесс создает пару манипуляторов функцией pipe, после чего создает потомка с помощью fork; в результате возникают два разных процесса, выполняющих одну и ту же программу, каждый из которых обладает копией связанных манипуляторов.

Неважно, какой процесс будет приемником, а какой - передатчиком; когда процесс начинает играть одну из этих ролей, его напарнику достается другая. Такой обмен данными может быть только односторонним (но не бросайте читать!)

Мы воспользуемся модулем IO;;Handle, в котором нас интересует метод autoflushO (еслн вы предпочитаете более эффективные решения, воспользуйтесь решением с select, описанным в главе 7). Если этого не сделать, наша отдельная строка вывода застрянет в канале и не доберется до другого конца до закрытия капала.

Версия родителя, передающего данные потомку, приведена в примере 16.3. Пример 16.3. pipel

#i/usr/bin/perl -w

» pipel - применение pipe и fork для отправки данных родителем потомку

use 10 Handle, pipe(READER WRITER), WRITER->autoflush(1),

If ($pid = fork) { close READER,

print WRITER Parent Pid $$ is sending this\n . close WRITER, waitpid($pid,0), > else {

die cannot fork $ unless defined $pid, close WRITER,

chomp($line = <READER>),

print Child Pid $$ ]ust read this $line \n close READER й Все равно это произойдет exit

В примерах этого рецепта основная проверка ошибок была оставлена читателю для самостоятельной работы Мы так поступили для того, чгобы взаимодействие функций стало более наглядным. В реальной жизни проверяются возвращаемые значения всех вызовов системных функций

В примере 16 4 показана версия потомка, передающего данные родителю

Пример 16.4. pipeZ

й/usr/bin/perl -W

й pipe2 - применение pipe и fork для передачи данных потомком родителю

use 10 Handle pipe(READER WRITER) WRITER->autoflush(1)

if ($pid = fork) { close WRITER chomp($line = <READER>)

print Parent Pid $$ just read this $line \n close READER waitpid($pid 0) } else {

die cannot fork $ unless defined $pid close READER

print WRITER Child Pid $$ is sending this\n , close WRITER й Все равно это произойдет exit

Обычно обе половины входят в цикл и приемник продолжает читать до конца файла. Это происходит до тех нор, пока передатчик не закроет канал или не завершится

Поскольку манипуляторы каналов работают лишь в одном направлении, каждый процесс использует лишь один канал из пары и закрывает неиспользуемый манипулятор. Причина, по которой это делается, нетривиальна; представьте себе ситуацию, при которой принимающий процесс не закрыл передающий манипулятор Если после этого передающий процесс завершится, пока принимающий процесс пытается что-нибудь прочитать, последний намертво «зависнет» Система не может сообщить приемнику о том, что данных для чтения больше не будет, пока не будут закрыты все копии передающего манипулятора.

Функция open, получая в качестве второго аргумента - или = , неявно вызывает pipe и fork. Это несколько упрощает приведенный выше фрагмент. Порожденный процесс общается с родителем через STDIN или STDOUT в зависимости от того, какая строка была использована, -1 или - .