Come consentire a due processi concorrenti di comunicare?

Question

Ho due processi separati: un programma C che emette valori separati da virgola seguiti da una nuova riga ogni secondo e un programma Perl che accetta i dati (nello stesso formato) e li elabora.

Le uscite di programma C (via printf) valori come tale:

1, 2, 3, 4, 5, 6 
7, 8, 9, 10, 11, 12 
... 

Il programma Perl si trova in un ciclo infinito attesa con il metodo per STDIN per elaborare questi dati:

while ($line = <STDIN>) 
{ 
    chomp($line) # Line should now read "1,2,3,4,5,6" 
    # Process data 
} 

Voglio che questi due processi comunichino in tempo reale. Le pipe bash standard non funzionano (ad esempio process1 | process2) perché il programma Perl attende che il primo programma finisca prima di elaborare l'input.

Qualcuno ha idee, suggerimenti o informazioni su una soluzione a questo problema? Grazie in anticipo!

Answer 1

I tubi dovrebbero andare bene per questo; devi solo controllare quando l'output del tuo programma C viene svuotato per renderlo disponibile allo script perl in modo incrementale. Puoi farlo nel programma C usando fflush(), che forzerà il buffer del tuo programma C a essere espulso in modo che il programma perl possa leggerlo.

Non c'è nulla di intrinseco nelle pipe che faccia sì che il programma perl attenda che il programma C termini la scrittura prima di elaborare il suo output. Il vostro programma Perl è scritto in modo che i processi STDIN una riga alla volta:

while ($line = <STDIN>) { ... } 

<> in questo contesto si legge una riga da STDIN, ma se non c'è una disposizione che bloccherà fino a quando si è. Una chiamata a fflush() dal programma C farà in modo che ciò accada.

Dai uno sguardo allo Wikipedia article on Pipelines. La sezione sull'implementazione fornisce una breve descrizione di come vengono bufferate le pipe, che dovrebbe aiutarti a capire come i tuoi processi comunicano. Le tubature do consentono la concomitanza tra processi e i processi di lettura e scrittura su pipe sono gestiti dallo scheduler proprio come altri processi. Il tuo problema qui è con il buffering.

Answer 2

Il programma C deve fflush() i suoi buffer di uscita esplicitamente o utilizzare una pty. Quest'ultimo è molto più imbarazzante, ma mantiene il codice C più semplice. Prova "man 3 fflush" se questo non ti è familiare.