典型的生產(chǎn)者消費(fèi)者模型(信號(hào)量、共享內(nèi)存)， 被中斷后的異常情況，求助

zxc381219

root@zxc:/home/zxc/work/IPC# ./ipc
I creat 3899290.030000          // 剛開(kāi)始都很正常，先創(chuàng)建后吃
I eat 3899290.030000
I creat 11594766.800000
I eat 11594766.800000
I creat 8487198.630000
I eat 8487198.630000
I creat 5467618.510000
I eat 5467618.510000
^CI get Init                  // 這里我點(diǎn)下了 ctrl+c
I eat 2465814.240000
I get Init
I creat 2465814.240000
I eat 2465814.240000
I creat 2465814.240000
I eat 20923460.250000      // 變成了 先吃 后創(chuàng)建。。。。  
I creat 20923460.250000
I eat 7156795.030000
I creat 7156795.030000
I eat 4110252.640000
I creat 4110252.640000

為毛啊？ 請(qǐng)大俠幫忙解釋一下 。

源碼：
#include "stdio.h"
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <sys/sem.h>
#include <sys/shm.h>
#include <sys/signal.h>

typedef struct
{
    double randnum;
}ShmStru;


int v(int semid,int semno)
{
    struct sembuf buf;
    memset(&buf,0,sizeof(struct sembuf));
    buf.sem_num=semno;
    buf.sem_op=1;
    buf.sem_flg=0;
    return semop(semid,&buf,1);

}


int p(int semid,int semno)
{
    struct sembuf buf;
    memset(&buf,0,sizeof(struct sembuf));
    buf.sem_num=semno;
    buf.sem_op=-1;
    buf.sem_flg=0;
    return semop(semid,&buf,1);

}

void handleSigint(int signo)
{
    printf("I get Init\n";
}

int main()
{
    key_t key;
    int semid,shmid;
    ShmStru *pstru;
    int semarray[2];
    pid_t pid;
    int n;


    signal(SIGINT,handleSigint);       //  這里截獲SIGINT信號(hào)

    if((key = ftok("/etc/profile",0))<0)
    {
        perror("ftok";
        exit(1);
    }
    if((semid = semget(key,2,IPC_CREAT|IPC_EXCL|0666))<0)
    {
        perror("semget";
        exit(2);
    }
    if((shmid=shmget(key,sizeof(ShmStru),IPC_CREAT|IPC_EXCL|0666))<0)
    {
        perror("shmget";
        exit(3);
    }
    if((pstru = shmat(shmid,NULL,0))==(void *)-1)
    {
        perror("shmat";
        exit(4);
    }
    semarray[0]=1;
    semarray[1]=0;
    if(semctl(semid,2,SETALL,semarray)<0)
    {
        perror("semctl";
        exit(5);
    }  
    pstru->randnum=0.00;
    if((pid = fork())==0)
    {
        for(;
        {
            p(semid,1);
            printf("I eat %f\n",pstru->randnum);        //消費(fèi)它，即打印到屏幕
            v(semid,0);
        }
    }else
    {
        //for(n=0;n<10;n++)
        for(;
        {
            p(semid,0);
            srand(time(NULL));
            pstru->randnum=(double)(rand()*0.01);     //Creat一個(gè)隨機(jī)浮點(diǎn)數(shù)
            sleep(1);
            printf("I creat %f\n",pstru->randnum);
            v(semid,1);
        }
        kill(pid,SIGKILL);
    }

    if(shmdt(pstru)==-1)
    {
        perror("shmdt";
        exit(6);
    }
    shmctl(shmid,IPC_RMID,0);
    semctl(semid,IPC_RMID,0);
    return 0;
}

timespace

回復(fù) 1# zxc381219
把代碼用code標(biāo)簽括起來(lái)，現(xiàn)在這樣沒(méi)法看啊


   

timespace

回復(fù) 1# zxc381219
輸出表明生產(chǎn)消費(fèi)邏輯已經(jīng)亂了
因?yàn)樾盘?hào)會(huì)讓semop返回錯(cuò)誤，請(qǐng)判斷其返回值


   

zxc381219

多謝回復(fù)  但是我記得信號(hào)量是不會(huì)被中斷的吧？

zxc381219

看了一下 函數(shù)的返回說(shuō)明
好像是可以被信號(hào)中斷的 返回值是 EINTR
返回說(shuō)明：
　　成功執(zhí)行時(shí)，兩個(gè)系統(tǒng)調(diào)用都返回0。失敗返回-1，errno被設(shè)為以下的某個(gè)值
　　E2BIG：一次對(duì)信號(hào)的操作數(shù)超出系統(tǒng)的限制
　　EACCES：調(diào)用進(jìn)程沒(méi)有權(quán)能執(zhí)行請(qǐng)求的操作，并且不具有CAP_IPC_OWNER權(quán)能
　　EAGAIN：信號(hào)操作暫時(shí)不能滿(mǎn)足，需要重試
　　EFAULT：sops或timeout指針指向的空間不可訪問(wèn)
　　EFBIG：sem_num指定的值無(wú)效
　　EIDRM：信號(hào)集已被移除
　　EINTR：系統(tǒng)調(diào)用阻塞時(shí)，被信號(hào)中斷
　　EINVAL：參數(shù)無(wú)效
　　ENOMEM：內(nèi)存不足
　　ERANGE：信號(hào)所允許的值越界

看來(lái)我應(yīng)該增加對(duì)EINTR的判斷 如果是它 continue;

原來(lái)PV不會(huì)被中斷是指 P或者V操作的瞬間過(guò)程不會(huì)被中斷，而如果在阻塞狀態(tài)，就會(huì)被中斷啦！

kprc

zxc381219 在嗎？

semarray[0]=1;
semarray[1]=0;

我試了一下將上面的值改成如下：

semarray[0]=0;
semarray[1]=1;

就不再打印了，我想不明白，為什么就不能打印成如下的樣子？
i eat ..
i creat ..
i eat ..
i creat ..
..