首页 手机软件 手机游戏 单机游戏 资讯文章 专题下载 游戏合集 文章合集 php下载 php教程 电脑软件
+ -
当前位置：首页 → 问答吧 → 请大家看看我的循环队列（无锁）会有问题吗，在多线程环境

请大家看看我的循环队列（无锁）会有问题吗，在多线程环境

时间：2010-08-14

来源：互联网

  1. typedef struct apr_socket_queue
  2. {
  3.         int size;
  4.         int *base;
  5.         volatile int writer;
  6.         volatile int reader;
  7. }apr_socket_queue;

  9. #include "datatype.h"
  10. #include <stdlib.h>

  12. #define HEAD  0
  13. #define TRUE  1
  14. #define FALSE 0

  16. void create_queue(apr_socket_queue *queue,apr_config *pconfig)
  17. {
  18.         queue->size = pconfig->socket_number;
  19.         queue->base = (int*)malloc(sizeof(int)*pconfig->socket_number);
  20.         queue->writer  = HEAD;
  21.         queue->reader  = HEAD - 1;
  22. }

  24. int enqueue(apr_socket_queue *queue,int socket)
  25. {
  26.         if(queue->writer+1 != queue->reader && queue->writer < queue->size-1)
  27.         {
  28.                 queue->base[queue->writer] = socket;
  29.                 queue->writer++;
  30.                 return TRUE;
  31.         }

  33.         if(queue->writer == queue->size-1 && queue->reader > HEAD)
  34.         {
  35.                 queue->base[queue->writer] = socket;
  36.                 queue->writer = HEAD;
  37.                 return TRUE;
  38.         }

  40.         return FALSE;//the queue is full
  41. }

  43. int dequeue(apr_socket_queue *queue,int *socket)
  44. {
  45.         if(queue->reader+1 != queue->writer && queue->reader < queue->size-1)
  46.         {
  47.                 queue->reader++;
  48.                 *socket = queue->base[queue->reader];
  49.                 return TRUE;
  50.         }

  52.         if(queue->reader == queue->size-1 && queue->writer > HEAD)
  53.         {
  54.                 queue->reader = HEAD;
  55.                 *socket = queue->base[queue->reader];
  56.                 return TRUE;
  57.         }

  59.         return FALSE;// the queue is empty
  60. }


  63. void destroy_queue(apr_socket_queue *queue)
  64. {
  65.         free(queue->base);
  66.         queue->writer = HEAD;
  67.         queue->reader = HEAD -1;
  68.         queue->size = 0;
  69. }
复制代码

作者: iCoding   发布时间: 2010-08-14

使用的话，生成两个线程，一个生产线程一个消费线程，生产线程只会调用enqueue,消费线程条用dequeue，这样的话会出问题吗

作者: iCoding   发布时间: 2010-08-14

循环缓冲貌似只有在单一消费者和单一生产者才是数据安全的吧~多了都要加锁

作者: wenkai169   发布时间: 2010-08-14

楼上说的对，当你的消费者是一个时，是可以这么用的。
如果有多个消费者，不加锁是不行的

作者: pdsxw123   发布时间: 2010-08-14



QUOTE:
循环缓冲貌似只有在单一消费者和单一生产者才是数据安全的吧~多了都要加锁
wenkai169 发表于 2010-08-14 10:42




    我预计确实只有一个生产者一个消费者，所以才这么写

作者: iCoding   发布时间: 2010-08-14

相关阅读 更多

热门阅读

热门下载

更多
关于本站 免责申明 联系我们

Copyright 2006-2020 php爱好者(phpfans.net) All Rights Reserved.备案号：湘ICP备2023016114号-2

本站为非盈利性网站，不接受任何广告。本站所有资源均由网友上传，如有侵权，请发邮件至 [email protected] phpfans.net