0

このコードを考えると：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/wait.h>
#include <unistd.h>

#define BUF_SIZE 256

int main()
{
    int fd1[2];
    int fd2[2];

    ssize_t numRead = -1;

    // remark : working under the assumption that the messages are of equal length

    const char* messageOne = "Hello world , I'm child number 1\n";
    const char* messageTwo = "Hello world , I'm child number 2\n";

    const unsigned int commLen = strlen(messageOne) + 1;

    char buf[BUF_SIZE];

    if (pipe(fd1) == -1)
    {
        printf("Error opening pipe 1!\n");
        exit(1);
    }

    if (pipe(fd2) == -1)
    {
        printf("Error opening pipe 2!\n");
        exit(1);
    }

    printf("Piped opened with success. Forking ...\n");

    // child 1
    switch (fork())
    {
        case -1:
            printf("Error forking child 1!\n");
            exit(1);

        case 0:
            printf("\nChild 1 executing...\n");
            /* close reading end of first pipe */
            if (close(fd1[0]) == -1)
            {
                printf("Error closing reading end of pipe 1.\n");
                _exit(1);
            }
            /* close writing end of second pipe */
            if (close(fd2[1]) == -1)
            {
                printf("Error closing writing end of pipe 2.\n");
                _exit(1);
            }

            /* write to pipe 1 */
            if (write(fd1[1], messageOne, commLen) != commLen)
            {
                printf("Error writing to pipe 1.\n");
                _exit(1);
            }

            if (close(fd1[1]) == -1)
            {
                printf("Error closing writing end of pipe 1.\n");
                _exit(1);
            }

            /* reding from pipe 2 */
            numRead = read(fd2[0], buf, commLen);
            if (numRead == -1)
            {
                printf("Error reading from pipe 2.\n");
                _exit(1);
            }

            if (close(fd2[0]) == -1)
            {
                printf("Error closing reding end of pipe 2.\n");
                _exit(1);
            }

            printf("Message received child ONE: %s", buf);
            printf("Exiting child 1...\n");
            _exit(0);
            break;

        default:
            break;
    }

    // child 2
    switch (fork())
    {
        case -1:
            printf("Error forking child 2!\n");
            exit(1);
        case 0:
            printf("\nChild 2 executing...\n");
            /* close reading end of second pipe */
            if (close(fd2[0]) == -1)
            {
                printf("Error closing reading end of pipe 2.\n");
                _exit(1);
            }
            /* close writing end of first pipe */
            if (close(fd1[1]) == -1)
            {
                printf("Error closing writing end of pipe 1.\n");
                _exit(1);
            }

            /* read from the first pipe */
            if (read(fd1[0], buf, commLen) == -1)
            {
                printf("Error reading from pipe 1.\n");
                _exit(EXIT_FAILURE);
            }

            if (close(fd1[0]) == -1)
            {
                printf("Error closing reading end of pipe 1.\n");
                _exit(EXIT_FAILURE);
            }

            /* write to the second pipe */
            if (write(fd2[1], messageTwo, commLen) != commLen)
            {
                printf("Error writing to the pipe.");
                _exit(EXIT_FAILURE);
            }

            if (close(fd2[1]) == -1)
            {
                printf("Error closing writing end of pipe 2.");
                _exit(EXIT_FAILURE);
            }

            printf("Message received child TWO: %s", buf);
            printf("Exiting child 2...\n");
            _exit(EXIT_SUCCESS);
            break;

        default:
            break;
    }

    printf("Parent closing pipes.\n");

    if (close(fd1[0]) == -1)
    {
        printf("Error closing reading end of the pipe.\n");
        exit(EXIT_FAILURE);
    }

    if (close(fd2[1]) == -1)
    {
        printf("Error closing writing end of the pipe.\n");
        exit(EXIT_FAILURE);
    }

    if (close(fd2[0]) == -1)
    {
        printf("Error closing reading end of the pipe.\n");
        exit(EXIT_FAILURE);
    }

    if (close(fd1[1]) == -1)
    {
        printf("Error closing writing end of the pipe.\n");
        exit(EXIT_FAILURE);
    }

    printf("Parent waiting for children completion...\n");
    if (wait(NULL) == -1)
    {
        printf("Error waiting.\n");
        exit(EXIT_FAILURE);
    }

    if (wait(NULL) == -1)
    {
        printf("Error waiting.\n");
        exit(EXIT_FAILURE);
    }

    printf("Parent finishing.\n");
    exit(EXIT_SUCCESS);
}

これは、 を使用した 2 つのプロセス間の簡単な会話pipe()です。

出力は次のとおりです。

Piped opened with success. Forking ...
Parent closing pipes.
Parent waiting for children completion...

Child 2 executing...

Child 1 executing...
Message received child TWO: Hello world , I'm child number 1
Exiting child 2...
Message received child ONE: Hello world , I'm child number 2
Exiting child 1...
Parent finishing.

上記からわかるように、2 人の子供は と を使用して互いに話し合っていforkますpipe。しかし、パイプなしでこれを行いたいのですが、可能ですか? もしそうなら、その方法を説明しpipe()てください pipe()。

ありがとう

4

4 に答える 4

5

なぜこれを行う必要があるのか​​ はわかりませんが、他にもいくつかの IPC メカニズムがあります (すべてより複雑で、エラーが発生しやすくなります)。

  • 名前付きパイプ (FIFO)
  • 共有メモリ
  • マップされた共有メモリ
  • UNIX ドメイン ソケット
  • インターネット ドメイン ソケット

これらの優れたチュートリアルについては、この電子書籍の「プロセス間通信」の章を参照してください: Advanced Linux Programming

于 2012-07-06T14:07:56.733 に答える
3

共有メモリまたは Unix ソケットを使用できます。パイプで十分な場合、なぜそうしたいのかわかりません。shmem と sockets はどちらもより低レベルです。

于 2012-07-06T14:04:11.323 に答える
3

System V共有メモリの例を示すために、プログラムを変更しました。競合状態を避けるために、セマフォ (POSIX 名前付きセマフォ) も使用されます。コメントも書いてあります。Pl。この例が役立つかどうかを確認してください。機能の詳細については、個々の機能のマニュアル ページを参照してください。コンパイル フラグは -lpthread にする必要があります。キーを生成するには (一意の共有メモリ セグメントを参照するため)、ftok 関数を使用したため、既存のファイル (「anyfile」という名前を付けました) を現在のディレクトリで使用できるようにする必要があります。Pl。関数の戻り値をチェックして、適切なエラー処理も追加します。

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/wait.h>
#include <unistd.h>
#include <fcntl.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <sys/shm.h>
#include <semaphore.h>

#define BUF_SIZE 256
int main()
{
    key_t key;
    char *virtualaddr;
    sem_t *get, *put;
    ssize_t numRead = -1;
    int shmid;

   const char* messageOne = "Hello world , I'm child number 1\n";
   const char* messageTwo = "Hello world , I'm child number 2\n";

   const unsigned int commLen = strlen(messageOne) + 1;
   char buf[BUF_SIZE];

   key = ftok("anyfile",'R');

  shmid = shmget(key,1024,0644|IPC_CREAT);
  if (0 > shmid)
  {
    perror("Shared Mem creation error\n");
    exit(1);

  }
//Attaching  the shared mem to my address space(available across fork)
 virtualaddr = shmat(shmid, (void*)0, 0);
  /*Create two POSIX Named Semaphores, get and put and initialising with 0*/
 get = sem_open("/get", O_CREAT|O_RDWR, 0644, 0);

 put = sem_open("/put", O_CREAT|O_RDWR, 0644, 0);

 // child 1
switch (fork())
{
    case -1:
        printf("Error forking child 1!\n");
        exit(1);
    case 0:
        printf("\nChild 1 executing...\n");
    //Referring the semaphores..
    get = sem_open ("/get", O_RDWR);
    put = sem_open ("/put", O_RDWR);

    //Child 1 writing in shared mem
        strcpy (virtualaddr, messageOne);
    //Child 1 signalling that now child 2 can write
        sem_post (get);
    //Child1 waiting for Child2 to write..
    sem_wait (put);
    //Child 1 reading from shared mem
    strcpy (buf, virtualaddr);          
    printf("Message received child ONE: %s", buf);
        printf("Exiting child 1...\n");
        _exit(0);
        break;
 default:
        break;
}
// child 2
switch (fork())
{
    case -1:
        printf("Error forking child 2!\n");
        exit(1);
    case 0:
        printf("\nChild 2 executing...\n");
    //Referring the semaphores..
    get = sem_open ("/get", O_RDWR);
    put = sem_open ("/put", O_RDWR);

    //Waiting Till Child 1 has written.
        sem_wait (get);
        //Now child 2 can read from shared memory
    strcpy (buf, virtualaddr);
    //Child 2 writing in shared mem
    strcpy (virtualaddr,messageTwo );
    //Signalling that now Child 1 can read.
    sem_post (put);                            
        printf("Exiting child 2...\n");
    printf("Message received child TWO: %s", buf);
        _exit(EXIT_SUCCESS);
        break;

    default:
        break;
}
printf("Parent waiting for children completion...\n");

if (wait(NULL) == -1)
{
    printf("Error waiting.\n");
    exit(EXIT_FAILURE);
}

if (wait(NULL) == -1)
{
    printf("Error waiting.\n");
    exit(EXIT_FAILURE);
}

printf("Parent finishing.\n");
//Deleting semaphores..
sem_unlink ("/get");
sem_unlink ("/put");
//Deleting Shared Memory.
shmctl (shmid, IPC_RMID, NULL);
exit(EXIT_SUCCESS);

}

于 2012-07-06T20:09:54.337 に答える
1
  1. Unixソケット
  2. 共有メモリ
  3. CORBA
  4. IPCメッセージパッシング（http://www.cs.cf.ac.uk/Dave/C/node25.htmlを参照）
  5. TCP/IPまたはUDP
  6. ファイルに書き込み、他のプロセスが読み取るためにセマフォを使用してフラグを立てることもできます。

頭のてっぺんから

于 2012-07-06T14:20:29.853 に答える