Chinaunix首页 | 论坛 | 博客
  • 博客访问: 544511
  • 博文数量: 150
  • 博客积分: 5010
  • 博客等级: 大校
  • 技术积分: 1861
  • 用 户 组: 普通用户
  • 注册时间: 2008-03-17 00:19
文章分类

全部博文(150)

文章存档

2011年(1)

2009年(14)

2008年(135)

我的朋友

分类: 项目管理

2008-04-06 12:15:40

if( i==10)
        {
            i=0;//when i is producer1_message[i]
            produer1_message[0]="producer1--1 ";;//as when the second loop ,show a unaccept info
            PC_DispStr(15,12,"                               ",font_color);

        }



void producer1(void *pdata)
{
    char *produer1_message[10]={
                                "producer1--1 ", "producer1--2",
                                "producer1--3", "producer1--4",
                                "producer1--5", "producer1--6",
                                "producer1--7", "producer1--8",
                                "producer1--9", "producer1--10",
                                };
    INT8U i=0;//product tag
    INT8U err;// save OSQPost() return infomation
    char delete_info[5];
    char display_info[20];
   
    pdata=pdata;

    for(;;)
    {
       
        if( i==10)
        {
            i=0;//when i is producer1_message[i]
            produer1_message[0]="producer1--1 ";//as when the second loop ,show a unaccept info
            PC_DispStr(15,12," ",font_color);
        }
        sprintf(delete_info,"%d",i);
        PC_DispStr(15,21,delete_info,font_color);
        PC_DispStr(15,22,produer1_message[i],font_color);
        err=OSQPost(q_buf,(void *)produer1_message[i]);
        switch(err)
        {//test err
                case OS_NO_ERR:
                {
                    sprintf( display_info,"producer1--%d success",i+1);
                    PC_DispStr(15,12,display_info,font_color);
                    break;
                }
                case OS_Q_FULL:
                {
                    PC_DispStr(15,12,"the buffer is full, don't add",font_color);
                    break;
                }
                default :break;
        }
        i++;
        OSTimeDly(400);
    }

}



1控制各任务等待的时间,可决定消费者,与生成者的关系。

 producer1:OSTimeDly(100);

producer2:OSTimeDly(100);

 consumer1:OSTimeDly(200);

consumer2:OSTimeDly(200);

这样生产者就使消息队列满了,

2

覆盖当10出现后,再出1 时,后面还有0,定义消息队列时,小于10的每个后面加一空格。

char *produer1_message[10]={

        "producer1--1 ", "producer1--2 ",

        "producer1--3 ", "producer1--4 ",

        "producer1--5 ", "producer1--6 ",

        "producer1--7 ", "producer1--8 ",

        "producer1--9 ",  "producer1--10", 

        };

3

不知为什么,当消息队列第一次満后,再从头添加消

阅读(1337) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~