Oprindeligt Indsendt af lagigliaivan

Jeg ikke forstår udmærket denne fred i kode, du skrev:

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

 if ( pid | (pid1 == 0) )

Oprindeligt Indsendt af p00ndawg

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

Oprindeligt Indsendt af tetsujin

OK, først ud, så du har alt fire processer her, ikke tre ... (Er det det, du ønskede? For den proces, jeg kalder en for at gyde off tre børn? Eller har du ønsker tre processer alt?)

Process A (original proces): pid \u003d B, pid1 \u003d C
Proces B (første barn af A): pid \u003d 0, pid1 \u003d D
Proces C (andet barn af A): pid \u003d B, pid1 \u003d 0
Proces D (barn af B): pid \u003d 0, pid1 \u003d 0



Dette hvis erklæring faktisk vil køre i tre af de fire processer: A, C og D:
Metode A: (pid | pid1 \u003d\u003d 0) \u003d (B | C \u003d\u003d 0) \u003d (B | 0) \u003d true
Proces B: (pid | pid1 \u003d\u003d 0) \u003d (0 | D \u003d\u003d 0) \u003d (0 | 0) \u003d false
Metode C: (pid | pid1 \u003d\u003d 0) \u003d (B | 0 \u003d\u003d 0) \u003d (B | true) \u003d true
Proces D: (pid | pid1 \u003d\u003d 0) \u003d (0 | 0 \u003d\u003d 0) \u003d (0 | true) \u003d true
(hvor sandt er nogle nonzero værdi ...)



p [2] er uninitialized. pipe () kun skaber to fil deskriptorer: p [0], Læste ende af røret, og p [1], Skrivebeskyttelsestappen ende af røret.

Også fra problemet beskrivelse det lød som du ville hver af de tre kommunikere processer for at have mulighed for at skrive beskeder til og modtage beskeder fra hver af de to andre kommunikere processer. Dette antyder, skal du oprette mindst tre rør (tre invocations af rør () i moderselskabet processen). Jeg siger "mindst tre rør", for hvis disse processer kører samtidigt, så to processer til at skrive til den samme fil deskriptor kunne have uforudsigelige resultater. (Med skriver () til at skrive et enkelt, hele beskeden vil formentlig være sikkert - men hvis budskabet var store er det muligt at skrive ville blokere venter for læseren at læse nogle data ud - og i så fald tror jeg, at det er muligt, den anden proces's skrive () kunne opløse ind før den første skrive () er færdig med sit budskab. (Ikke sikker på, selv om. skrive () er et system opkald så kernen mai synkronisere det ...)

Husk, at røret () opretter to fil deskriptorer men bare en pipe. Et rør med et input ende og et output ende. En fil deskriptor får du fra pipe () er enten skrivebeskyttet eller skrive-only - man aldrig kan læse og skrive fra den samme fil deskriptor, når filen deskriptor blev opnået med pipe ().

Oprindeligt Indsendt af p00ndawg

ja jeg ville egentlig bare processer A, B og C at kommunikere med hinanden, men jeg vil blot pipe en besked fra a-> b-> c. Jeg gjorde ikke indse jeg havde skabt 4 processer.
Er der alligevel kun oprette 3 processer? hvordan ser en måde at lige få variable rør kommunikere med hinanden?

Oprindeligt Indsendt af tetsujin

Sikker. Grunden du afsluttes med i alt fire processer er fordi hvert opkald til bord () returnerer to gange: én gang i den oprindelige proces og en gang i den nye. Så når du har foretaget den første indkaldelse til bord (), er der to processer - som begge går på at kalde det andet fork ().

At skabe en alt tre processer, at du kun gaffelgreb to gange. Du kan gøre dette ved at kontrollere den returnerede værdi af fork () til at sikre, at du i den proces, der bør gaffel.

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);
    }
}