典型的生产者消费者模型(信号量、共享内存)， 被中断后的异常情况，求助

zxc381219

root@zxc:/home/zxc/work/IPC# ./ipc
I creat 3899290.030000          // 刚开始都很正常，先创建后吃
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                  // 这里我点下了 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      // 变成了 先吃 后创建。。。。  
I creat 20923460.250000
I eat 7156795.030000
I creat 7156795.030000
I eat 4110252.640000
I creat 4110252.640000

为毛啊？ 请大侠帮忙解释一下 。

源码：
#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信号

    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);        //消费它，即打印到屏幕
            v(semid,0);
        }
    }else
    {
        //for(n=0;n<10;n++)
        for(;
        {
            p(semid,0);
            srand(time(NULL));
            pstru->randnum=(double)(rand()*0.01);     //Creat一个随机浮点数
            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

回复 1# zxc381219
把代码用code标签括起来，现在这样没法看啊


   

timespace

回复 1# zxc381219
输出表明生产消费逻辑已经乱了
因为信号会让semop返回错误，请判断其返回值


   

zxc381219

多谢回复  但是我记得信号量是不会被中断的吧？

zxc381219

看了一下 函数的返回说明
好像是可以被信号中断的 返回值是 EINTR
返回说明：
　　成功执行时，两个系统调用都返回0。失败返回-1，errno被设为以下的某个值
　　E2BIG：一次对信号的操作数超出系统的限制
　　EACCES：调用进程没有权能执行请求的操作，并且不具有CAP_IPC_OWNER权能
　　EAGAIN：信号操作暂时不能满足，需要重试
　　EFAULT：sops或timeout指针指向的空间不可访问
　　EFBIG：sem_num指定的值无效
　　EIDRM：信号集已被移除
　　EINTR：系统调用阻塞时，被信号中断
　　EINVAL：参数无效
　　ENOMEM：内存不足
　　ERANGE：信号所允许的值越界

看来我应该增加对EINTR的判断 如果是它 continue;

原来PV不会被中断是指 P或者V操作的瞬间过程不会被中断，而如果在阻塞状态，就会被中断啦！

kprc

zxc381219 在吗？

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

我试了一下将上面的值改成如下：

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

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