搜索
bottom↓
回复: 1

求助:想给Protothreads加个消息队列,消息不能重复发送

[复制链接]

出0入0汤圆

发表于 2008-1-3 09:09:34 | 显示全部楼层 |阅读模式
求助:想给Protothreads加个消息队列,同一个消息控制块(具体消息内容不同)不能重复发送,
重复发送要么覆盖,要么成死结。



typedef struct _Object
{
   struct _Object *next;
}_Object_t;


typedef struct _MSG
{    struct  _MSG *next;
     uint8 data;
}MSG_t;

typedef struct _MSGQ
{
    MSG_t * msg;  
}MSGQ_t;


void MSG_Post(MSGQ_t *p_msg_queue, MSG_t *p_msg);
MSG_t * MSG_Pend(MSGQ_t *p_msg_queue);


void _AppendObject(void *pQueue, void *pObject)  //Object加到队列Queue尾部
{
   _Object_t * q = (_Object_t *)pQueue, *p = (_Object_t *)pObject;
     
   while(q->next)
   {
     q=q->next;
   }

   q->next=p;
   p->next = NULL;
}

void *_RemoveFirstObject(void *pQueue)   //取出队列Queue头部
{
  
      _Object_t  *p,*q=(_Object_t *)pQueue;   
      
     if(q->next)   //如果队列有数据
      {
        if(p=q->next) //如果队列还有下一个数据
        {
        q->next=p; //下一个数据为队列头部
        }
      
      else                //如果队列无下一个数据
      {
        q->next=NULL; //队列为空
       }
      return p;          //返回第一个数据
   }
   else                  //如果队列没有数据
   {
      return NULL;    //返回空指针      
   }
   
}


void MSG_Post(MSGQ_t *p_msg_queue, MSG_t *p_msg)
{
_AppendObject(p_msg_queue,p_msg);  
}

MSG_t * MSG_Pend(MSGQ_t *p_msg_queue)
{
return  (MSG_t *)_RemoveFirstObject(p_msg_queue); }

阿莫论坛20周年了!感谢大家的支持与爱护!!

一只鸟敢站在脆弱的枝条上歇脚,它依仗的不是枝条不会断,而是自己有翅膀,会飞。

出0入0汤圆

 楼主| 发表于 2008-1-3 22:19:54 | 显示全部楼层
继续问:
消息队列处理方法。
回帖提示: 反政府言论将被立即封锁ID 在按“提交”前,请自问一下:我这样表达会给举报吗,会给自己惹麻烦吗? 另外:尽量不要使用Mark、顶等没有意义的回复。不得大量使用大字体和彩色字。【本论坛不允许直接上传手机拍摄图片,浪费大家下载带宽和论坛服务器空间,请压缩后(图片小于1兆)才上传。压缩方法可以在微信里面发给自己(不要勾选“原图),然后下载,就能得到压缩后的图片】。另外,手机版只能上传图片,要上传附件需要切换到电脑版(不需要使用电脑,手机上切换到电脑版就行,页面底部)。
您需要登录后才可以回帖 登录 | 注册

本版积分规则

手机版|Archiver|amobbs.com 阿莫电子技术论坛 ( 粤ICP备2022115958号, 版权所有:东莞阿莫电子贸易商行 创办于2004年 (公安交互式论坛备案:44190002001997 ) )

GMT+8, 2024-5-20 19:44

© Since 2004 www.amobbs.com, 原www.ourdev.cn, 原www.ouravr.com

快速回复 返回顶部 返回列表