0

私はセマフォと共有メモリを扱っています。11 個のサブプロセスを作成する必要があります。最初にI = 0でAを印刷し、他のプロセスでBを印刷します。次に、カウンター付きのメッセージを印刷する各プロセスが必要な*APtrので、出力に1〜11の番号の行があり、その後にプロセスの意味と最後の行の* APtrの最終値が続きます。 12 である必要があります。

今は機能していません。プロセスは同時に *APtr の書き込みと読み取りを行っているため、1、1、1、4、5、6、7、7、8、8、11、12 などの最初の数字で出力を取得します。

int I, A;
int *APtr;
//create shared memory (action counter)
if((A=shmget(ftok(argv[0],getpid()), sizeof(int),  IPC_CREAT | 0660)) == -1)
{
    exit(2);
}
if((APtr=shmat(A,NULL,0)) == NULL)
{
    exit(2);
}
*APtr = 1;


/*semaphor semA*/
sem_t semA;
if(sem_init(&semA, 0, 1)==-1)
{
    exit(2);
}
/*semafor semA*/
pid_t pid;
for(int i=0; i<11; ++i)
{
    if((pid = fork()) < 0)
    {     //chyba spusteni noveho procesu
        kill(0, SIGTERM);
        exit(2);
    }
    else if(pid == 0)
    {
        I=i;
        if(I == 0)//A
        {
            sem_wait(&semA);
            //int pom = *APtr;
            fprintf(stdout, "%d: A %d:\n", *APtr, I);
            fflush(stdout);
            *APtr+=1;
            sem_post(&semA);
        }
        else//B
        {
            sem_wait(&semA);
            //int pom = *APtr;
            fprintf(stdout, "%d: B %d:\n", *APtr, I);
            fflush(stdout);
            *APtr+=1;
            sem_post(&semA);
        }
        break;
    }
    else
    {
        //fprintf(stdout, "%d\n", *APtr);
    }
}
sem_destroy(&semA);
if(pid != 0)
{
    sleep(1);
    fprintf(stdout, "%d\n", *APtr);
}
return 0;

私が正しく理解していればsem_init(&semA, 0, 1);、セマフォを初期化して、コマンドが完了sem_wait(&semA);するまで1つのプロセスのみが機能するようにする必要があります。sem_post(&semA);それで、私は何をしていますか/理解が間違っていますか?

sem_open() に切り替えた後、NULL が返され、フォークされたすべてのプロセスが sem_wait() でクラッシュしました。新しいコードがあります。

int I, A;
int *APtr;
//create shared memory (action counter)
if((A=shmget(ftok(argv[0],getpid()), sizeof(int),  IPC_CREAT | 0660)) == -1)
{
    exit(2);
}
if((APtr=shmat(A,NULL,0)) == NULL)
{
    exit(2);
}
*APtr = 1;


/*semaphor semA*/
sem_t *semA;
if(semA = sem_open("/semA", O_CREAT, 0700, 1) == SEM_FAILED)
{
    exit(2);
}
/*semafor semA*/
pid_t pid;
for(int i=0; i<11; ++i)
{
    if((pid = fork()) < 0)
    {     //chyba spusteni noveho procesu
        kill(0, SIGTERM);
        exit(2);
    }
    else if(pid == 0)
    {
        I=i;
        if(I == 0)//A
        {
            sem_wait(semA);
            fprintf(stdout, "%d: A %d:\n", *APtr, I);
            fflush(stdout);
            *APtr+=1;
            sem_post(semA);
        }
        else//B
        {
            sem_wait(semA);
            fprintf(stdout, "%d: B %d:\n", *APtr, I);
            fflush(stdout);
            *APtr+=1;
            sem_post(semA);
        }
        break;
    }
    else
    {
        //fprintf(stdout, "%d\n", *APtr);
    }
}
if(pid != 0)
{
    sleep(1);
    sem_close(semA);
    fprintf(stdout, "%d\n", *APtr);
}
return 0;
4

2 に答える 2

1 
sem_t semA;
if(sem_init(&semA, 0, 1)==-1)

ここでのセマフォは共有メモリではなく、スタック上にあります。

したがって、fork() した後、各プロセスはこのセマホの独自のコピーを持ちます。すべてのプロセスが同じセマフォにアクセスできるように、作成した共有メモリのどこかにセマフォを配置する必要があります。

sem_init() の代わりに、sem_open() を使用して名前付きセマホを作成できます。これは、それを開いた人の間で共有されます。

于 2013-04-23T09:24:34.383 に答える