Межпроцессное взаимодействие без FIFO

Вот пример, который запускает два подпроцесса, реализованных как функции одного и того же сценария оболочки ... Один подпроцесс генерирует числа 1 ... 5 (засыпает между отпечатками), второй читает из фиксированного файлового дескриптора (5, в который STDOUT из первый FD перенаправляется на), умножается на 2 и снова печатается. Основной процесс перенаправляет STDOUT этого второго процесса на другой фиксированный файловый дескриптор (6), а затем читает из этого в цикле.

Он работает в основном так же, как и в C-коде, с парами fd, созданными системным вызовом pipe (2). Чтобы понять, что происходит, запустите сценарий под strace -f!

Версия Bash - 4.2.24 (1), работающая на Ubuntu / x86.

[ubuntu /home/chris]
$ bash --version
GNU bash, version 4.2.24(1)-release (i686-pc-linux-gnu)
Copyright (C) 2011 Free Software Foundation, Inc.
License GPLv3+: GNU GPL version 3 or later <http://gnu.org/licenses/gpl.html>

This is free software; you are free to change and redistribute it.
There is NO WARRANTY, to the extent permitted by law.

Вывод скрипта:

[ubuntu /home/chris]
$ ./read_from_fd.sh
Got number 2.
Got number 4.
Got number 6.
Got number 8.
Got number 10.

Исходный код:

#!/bin/bash

# Generate data, output to STDOUT.
generate_five_numbers() {
        for n in `seq 5` ; do
                echo $n
                sleep 2
        done
}

# Read data from FD#5, multiply by two, output to STDOUT.
multiply_number_from_fd5_by_two() {
        while read n <&5 ; do
                echo "$(( $n * 2 ))"
        done
}

# choose your FD number wisely ;-)

# run generator with its output dup'ed to FD #5
exec 5< <( generate_five_numbers )

# run multiplyier (reading from fd 5) with output dup'ed to FD #6
exec 6< <( multiply_number_from_fd5_by_two )

# read numbers from fd 6
while read n <&6 ; do
        echo "Got number $n."
done

Дерево процессов во время работы:

──read_from_fd.sh(8118)─┬─read_from_fd.sh(8119)───sleep(8123)
                        └─read_from_fd.sh(8120)

Bash 4 имеет сопроцессы.

Вы также можете использовать анонимные именованные каналы, также известные как подстановка процесса в Bash. 2, 3 или 4.

Вы можете использовать nc (также известный как netcat), который позволяет подключать стандартные потоки скрипта к сети. разъем. Конечно, он также работает на localhost, поэтому вы можете использовать его для IPC между скриптами. Бонусом является возможность запускать скрипты на разных хостах, что невозможно с FIFO (хорошо, возможно, на NFS это так, но это было бы довольно громоздко для настройки, если у вас еще нет NFS).

Я просто хочу указать на то, что уродливые хаки не хотели такими родиться.

Часть, которая получает данные:

node -e "require('net').createServer(function(s){s.pipe(process.stdout)}).listen(1337)"

Часть, которая отправляет данные:

echo "write clean code they said" > /dev/tcp/localhost/1337
echo "it will pay off they said" > /dev/tcp/localhost/1337

К моему удивлению, работает даже в Bash от MSysGit для Windows.

Вы рассматривали возможность использования сигналов? Если единственное, что вам нужно, это вызвать событие (без передачи аргументов), использование kill и trap работает отлично (однако будьте осторожны с семантикой, используйте, например, SIGUSR1).

Однако вам может потребоваться переработать логику, как в примере ниже:

subprocess_finished()
{
    np=$( jobs -p | wc -l )
}

start_processing()
{
    myfile="$1"
    # DO SOMETHING HERE!!
    kill -SIGUSR1 $2
}

CPUS=$( lscpu | grep "^CPU(s):" | rev | cut -f 1 -d ' ' | rev )
POLLPERIOD=5  # 5s between each poll
np=0
trap subprocess_finished SIGUSR1

for myfile in *
do 
        start_processing "$myfile" $$ &
        np=$( jobs -p | wc -l )
        echo "$( date +'%Y-%m-%d %H:%M:%S' ) [$!] Starting #$np on $CPUS: $myfile"

        if [ $np -eq $CPUS ] 
        then
            # Wait for one CPU to be free
            trap subprocess_finished SIGUSR1
            while [ $np -eq $CPUS ]
            do
                sleep $POLLPERIOD
            done
        fi
    done
done

# wait for the last subprocesses
while [ ! -z "$( jobs -rp )" ]
do
    sleep $POLLPERIOD
done