Почему ожидание не может работать для процесса чтения в именованном канале? - PullRequest
Новая
       119

Почему ожидание не может работать для процесса чтения в именованном канале?

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

wait в bash - процесс для изменения состояния. В следующем сценарии bash создайте именованный канал и откройте 5 процессов для записи в него потока данных и откройте 1 процесс для чтения потока данных из его в другой файл. 

cat pipe.sh
fifo_file=fifo.pipe
mkfifo $fifo_file
exec 6<>$fifo_file
rm $fifo_file

DateWrite ()
{
    i=0
    while [[ $i -lt 200 ]]
    do
        str=`date`
        i=$(( i+1 ))
        echo "$i $str"
    done
}

writers=()
for  (( i=0; i<5; i++ ))
do 
    DateWrite >&6  & 
    echo "add a writer process pid  $!"
    writers+=($!)
done


while read date_time
do
    echo $date_time >> output.file 
done  <&6  &
reader=$!

for writer in "${writers[@]}" 
do
    wait "$writer"
    echo "the status of writer process pid $writer changed"   
done

echo "reader process pid is $reader"
wait  "$reader"
echo "the status of reader process pid $reader changed"   

exec 6<&-

Чтобы проверить команду ожидания в pipe.sh с помощью bash pipe.sh. 

add a writer process pid  4749
add a writer process pid  4750
add a writer process pid  4751
add a writer process pid  4752
add a writer process pid  4753
the status of writer process pid 4749 changed
the status of writer process pid 4750 changed
the status of writer process pid 4751 changed
the status of writer process pid 4752 changed
the status of writer process pid 4753 changed
reader process pid is 4754

Информационный список не содержит 

the status of reader process pid 4754 changed

Оператор wait "$reader" выполняется в течение бесконечного времени l oop, это нормально, что wait не может работать.
Если я удалю буксирные строки: 

wait  "$reader"
echo "the status of reader process pid $reader changed"

И выполнить bash pipe.sh: 

add a writer process pid  19670
add a writer process pid  19671
add a writer process pid  19673
add a writer process pid  19674
add a writer process pid  19675
the status of writer process pid 19670 changed
the status of writer process pid 19671 changed
the status of writer process pid 19673 changed
the status of writer process pid 19674 changed
the status of writer process pid 19675 changed
reader process pid is 19676

Искать pid 19676 в консоли. 

ps aux |grep '[p]ipe'
debian   19676  0.0  0.0  16516  2100 pts/1    S    19:54   0:00 bash pipe.sh

Процесс чтения, созданный в pipe.sh, все еще работает, когда pipe.sh завершен.
Я не хочу заменять wait "$reader" на kill "$reader" в pipe.sh.
Есть ли способ узнать, что echo $date_time прочитал конец канала, и послать сигнал для закрытия процесса чтения?

@ Филипп и все здесь друзья, sleep 1; echo q >&6, может быть, временной интервал такой короткий. Давайте предположим более сложный случай: 

while read date_time
do
    test "$date_time" = q && exit
    echo $date_time >> output.file 
    bash_some_code_do_some_thing
done  <&6  &

Время работы bash_some_code_do_some_thing больше, чем 10 секунд, минимум 10 секунд, не больше 10 секунд, и вы не можете оценить точное время. Нельзя написать такой код, как 

sleep 10; echo q >&6

или

sleep 100 ; echo q> & 6 # а если время работы на 200 секунд больше?

Как тогда решать кейс?

1 Ответ

1 голос
/ 05 мая 2020

Невозможно отправить EOF каналу, открытому для чтения-записи. Один способ - отправить команду выхода: 

fifo_file=fifo.pipe
mkfifo $fifo_file
exec 6<>$fifo_file
rm $fifo_file

DateWrite ()
{
    i=0
    while [[ $i -lt 200 ]]
    do
        str=`date`
        i=$(( i+1 ))
        echo "$i $str"
    done
}

writers=()
for  (( i=0; i<5; i++ ))
do 
    DateWrite >&6  & 
    echo "add a writer process pid  $!"
    writers+=($!)
done


while read date_time
do
    test "$date_time" = q && exit
    echo $date_time >> output.file 
done  <&6  &
reader=$!

for writer in "${writers[@]}" 
do
    wait "$writer"
    echo "the status of writer process pid $writer changed"   
done

echo "reader process pid is $reader"
sleep 1; echo q >&6
wait  "$reader"
echo "the status of reader process pid $reader changed"   

exec 6<&-

Другой способ - отправить сигнал TERM читателю.

...