2

最終的には生産者/消費者問題を解決しようとしていますが、最初にセマフォを使用してクリティカルセクションを作成できるようにする必要があります。私が現在抱えている問題は、プログラムを実行するときに、クリティカルセクションに複数のプロセスが入ることがあることです。一度に1つのプロセスだけをクリティカルセクションに入れたいと思っています。これが私が現在持っているコードです：

#include <stdio.h>
#include <stdlib.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/sem.h>

#define MAX 20

int main(void)
{
    key_t key = 1114;
    int semid, count,
        mutex = 0;


    //Initialize Semaphore Buffers
    struct sembuf oper0;

    pid_t waitId;
    pid_t parentId = getpid();

    //Create processes
    for(count = 0; count < MAX; count++)
    {
        if((waitId = fork()) == 0)
        {
            break;
        }
    }

    //Create a semaphore set of 3; I will be adding more semaphores
    if ((semid = semget(key, 3, 0600 | IPC_CREAT)) == -1) {
        printf("error in semget");
        exit(1);
    }

    // BINARY/MUTEX - initialize semaphore0 to 1 
    if(semctl(semid, mutex, SETVAL, 1) == -1)
    {
        printf("error in semctl");
        exit(0);
    }

    //Decrement semaphore 0
    oper0.sem_op = -1;
    oper0.sem_flg = 0;
    if (semop(semid, &oper0, 1) == -1) {
        printf("error decrementing semaphore \n");
        exit(1);
    }

    printf(" -- CRITICAL SECTION START ----------- \n\n");
    printf("%5d    %d     %s\n", getpid(), semctl(semid, 0, GETVAL, oper0.sem_num), " -- Semaphore 0");
    printf(" -- CRITICAL SECTION END -- \n\n");    

    //Increments semaphore 0
    oper0.sem_op = 1;
    oper0.sem_flg = 0;
    if (semop(semid, &oper0, 1) == -1) {
        printf("error incrementing semaphore \n");
        exit(1);
    }

    int i;
    if(getpid() == parentId)
    {
        for(i = 0; i < MAX i++)
        {
            wait(&waitId);
        }
    }
    else
    {
        exit(waitId);
    }

    // Remove semaphore 
    if (semctl(semid, 0, IPC_RMID) == -1) {
        printf("error in semctl");
        exit(1);
    }

    return 0;
}

出力例は次のとおりです。

 -- CRITICAL SECTION START ----------- 

 1097    0      -- Semaphore 0
 -- CRITICAL SECTION END -- 

 -- CRITICAL SECTION START ----------- 

 1085    0      -- Semaphore 0
 -- CRITICAL SECTION END -- 

 -- CRITICAL SECTION START ----------- 

 -- CRITICAL SECTION START ----------- 

 1095    0      -- Semaphore 0
 -- CRITICAL SECTION END -- 

 1093    0      -- Semaphore 0
 -- CRITICAL SECTION END -- 

 -- CRITICAL SECTION START ----------- 

 -- CRITICAL SECTION START ----------- 

 1087    0      -- Semaphore 0
 -- CRITICAL SECTION END -- 

 1089    0      -- Semaphore 0
 -- CRITICAL SECTION END -- 

 -- CRITICAL SECTION START ----------- 

 1091    0      -- Semaphore 0
 -- CRITICAL SECTION END --

セマフォが1つのプロセスでロックされる場合と、2つのプロセスが入る場合があるのはなぜですか？

4

1 に答える 1

3

あなたsemctl(semid, mutex, SETVAL, 1)はすべての子供に実行するからです。あなたは本当に一度だけそれをしたいです。セマフォを作成して初期化する場所の後にフォークループを移動すると、見栄えがよくなることがわかります。

また、printfの後にfflush（stdout）することもできます。stdoutがバッファリングされている場合、バッファがクリティカルセクションに書き込まれていても、出力が混ざり合う可能性があります。

于 2012-10-03T04:13:13.487 に答える