Inter-Prozess-Kommunikation ohne FIFOs

Hier ist ein Beispiel, das läuft in zwei Teilprozessen implementiert, die als Funktionen von der gleichen shell-Skript... Ein Unterprozess erzeugt die zahlen 1...5 (schläft in zwischen-Drucke), die zweite liest man von einem festen filedescriptors (5, um die STDOUT von der ersten FD weitergeleitet wird), multipliziert das Ergebnis mit 2 und druckt wieder. Die wichtigsten Prozess-Umleitungen von STDOUT des zweiten Prozesses zu anderen festen filedescriptors (6) und später liest, dass man in der Schleife.

Es funktioniert im Grunde das gleiche wie Sie tun würde, in C-code mit fd-Paare erzeugt, die durch das Rohr(2) - Systemaufruf. Um zu verstehen, was geschieht, führen Sie das Skript unter strace -f!

Bash-Version 4.2.24(1) unter 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.

Ausgabe des Skripts:

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

Source code:

#!/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

Prozess-Baum während der Ausführung:

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

InformationsquelleAutor Christian Vogel

Könnten Sie nc (aka netcat), die ermöglicht den Anschluss von einem Skript die standard-streams an einen Netzwerk-socket. Natürlich funktioniert es auch auf localhost, so können Sie es verwenden, für die IPC zwischen den Skripts. Der bonus die Möglichkeit zu haben, die Scripte laufen auf unterschiedlichen hosts ist nicht möglich, mit FIFOs (OK, vielleicht auf NFS ist es, aber das wäre sehr umständlich zum einrichten, es sei denn, Sie haben bereits den NFS).

InformationsquelleAutor Michał Kosmulski

Haben Sie als die Verwendung der Signale? Wenn die einzige Sache, die Sie benötigen, um ein Ereignis auszulösen (ohne übergabe von Argumenten), mit töten und in die Falle funktioniert perfekt (vorsichtig sein, die Semantik jedoch, verwenden Sie SIGUSR1 zum Beispiel).

Müssen Sie möglicherweise zu überarbeiten, die Logik aber, wie im Beispiel unten:

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

InformationsquelleAutor Fabien Bouleau