Ursprungligen postat av lagigliaivan

Jag förstår inte mycket väl denna fred i koden som du skrev:

if(pid | pid1 == 0)//process A

 if ( pid | (pid1 == 0) )

Ursprungligen postat av p00ndawg

pid = fork();
pid1 = fork();

Ursprungligen postat av tetsujin

OK, första start, du har ett totalt fyra processer, inte tre ... (Är det vad du ville? För att jag kallar A för att leka bort tre barn? Eller har du tre processer totalt?)

Process A (ursprungliga processen): pid \u003d B, pid1 \u003d C
Process B (första barnet av A): pid \u003d 0, pid1 \u003d D
Process C (andra barnet av A): pid \u003d B, pid1 \u003d 0
Process D (barn B): pid \u003d 0, pid1 \u003d 0



Detta om meddelandet verkligen kommer att löpa under tre av de fyra processer: A, C och D:
Process A: (pid | pid1 \u003d\u003d 0) \u003d (B | C \u003d\u003d 0) \u003d (B | 0) \u003d sant
Process B: (pid | pid1 \u003d\u003d 0) \u003d (0 | D \u003d\u003d 0) \u003d (0 | 0) \u003d false
Process C: (pid | pid1 \u003d\u003d 0) \u003d (B | 0 \u003d\u003d 0) \u003d (B | true) \u003d sant
Process D: (pid | pid1 \u003d\u003d 0) \u003d (0 | 0 \u003d\u003d 0) \u003d (0 | true) \u003d sant
(där sant är några nonzero värde ...)



p [2] är avinitieras. pipe () bara skapa två fil deskriptorer: p [0]Har läst slutet av röret, och p [1]De skriver slutet av röret.

Även från problemet beskrivning det lät som om du ville ha var och en av de tre kommunicerande processer för att få möjlighet att skriva meddelanden till och ta emot meddelanden från de andra två kommunicerande processer. Detta tyder på att du måste skapa minst tre ledningar (tre invocations i pipe () i moderbolaget process). Jag säger "minst tre pipor" för om dessa processer körs samtidigt, vilket gör att två processer för att skriva till samma fil deskriptor kunde ha oförutsägbara resultat. (Använda skriva () för att skriva ett enda, hela meddelandet kommer förmodligen att vara säker - men om meddelandet var stor är det möjligt att skriva skulle blockera väntar för läsaren att läsa vissa uppgifter ut - i så fall tror jag det är möjligt att andra processen är att skriva () skulle kunna avveckla få in innan den första att skriva () avslutar brevet. (Ej säker dock. skriva () är ett system samtal så kärnan maj synkronisera det ...)

Kom ihåg att röret () skapar två fil deskriptorer men bara ett pip. Ett rör med en ingång slut och en uteffekt slut. En fil deskriptor du får från röret () antingen är skrivskyddad eller skriva-bara - du kan aldrig läsa och skriva från samma fil deskriptor, när filen deskriptor erhölls med pipe ().

Ursprungligen postat av p00ndawg

ja jag egentligen ville processer A, B och C kommunicera med varandra, men jag ville bara röret ett meddelande från a-> b-> c. I didnt inser jag hade skapat 4 processer.
Finns det något sätt att bara skapa 3 processer? Vad sägs om ett sätt att bara få rörliga ledningar kommunicerar med varandra?

Ursprungligen postat av tetsujin

Säker. Anledningen du avvecklas med totalt fyra processer är att varje samtal till bord () återvänder två gånger: en gång i den ursprungliga processen och en gång på den nya. Så när du gör det första samtalet till bord () finns det två processer - som båda går på för att ringa upp andra bord ().

För att skapa ett totalt tre processer, se till att du endast bord två gånger. Du kan göra detta genom att kontrollera returvärdet av bord () för att se till att du är i processen som bör gaffelgrepp.

pid_b = fork();
if (pid_b == 0)
{
    /* fork() returned 0, so this is the new process, which I call process B. */
    pid_c = fork();
    if (pid_c == 0)
    {
        /* This is process C... */
    }
}

pipe(channel_ab);
 pid_b = fork();
if (pid_b > 0)
{
    /* Process A...  Send messages to B using channel_ab[1] */
    close(channel_ab[0]);
    write(channel_ab[1], msg, size);
} else if (pid_b == 0) {
    /* Process B */
    close(channel_ab[1]);

    pipe(channel_bc);
    pid_c = fork();
    if (pid_c > 0)
    {
        /* Still process B.  Receive messages from A using channel_ab[0], send messages to C using channel_bc[1]. */
        close(channel_bc[0]);
        msg_size = read(channel_ab[0], buffer, size);
        write(channel_bc[1], msg, size);
    } else if (pid_c == 0) {
        /* Process C.  Receive messages from B using channel_bc[0]. */
        msg_size = read(channel_bc[0], buffer, size);
    }
}