免费注册 查看新帖 |

Chinaunix

  平台 论坛 博客 文库
最近访问板块 发新帖
查看: 1601 | 回复: 1
打印 上一主题 下一主题

典型的生产和消费模型(信号量、共享内存),中断后的异常,求助 [复制链接]

论坛徽章:
0
跳转到指定楼层
1 [收藏(0)] [报告]
发表于 2012-05-06 11:15 |只看该作者 |倒序浏览
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;
}

论坛徽章:
0
2 [报告]
发表于 2012-05-06 19:34 |只看该作者
知道啦 结贴

semop在阻塞时 会被信号中断

应该增加对返回码的判断  如果返回码是EINTR 则continue; )
您需要登录后才可以回帖 登录 | 注册

本版积分规则 发表回复

  

北京盛拓优讯信息技术有限公司. 版权所有 京ICP备16024965号-6 北京市公安局海淀分局网监中心备案编号:11010802020122 niuxiaotong@pcpop.com 17352615567
未成年举报专区
中国互联网协会会员  联系我们:huangweiwei@itpub.net
感谢所有关心和支持过ChinaUnix的朋友们 转载本站内容请注明原作者名及出处

清除 Cookies - ChinaUnix - Archiver - WAP - TOP