请大家看看我的循环队列（无锁）会有问题吗，只有一个生产线程一个读取线程

iCoding

1. 
   
2. 
   
3. typedef struct apr_socket_queue
   
4. {
   
5.         int size;
   
6.         int *base;
   
7.         volatile int writer;
   
8.         volatile int reader;
   
9. }apr_socket_queue;
   
10. 
    
11. #include "datatype.h"
    
12. #include <stdlib.h>
    
13. 
    
14. #define HEAD  0
    
15. #define TRUE  1
    
16. #define FALSE 0
    
17. 
    
18. void create_queue(apr_socket_queue *queue,apr_config *pconfig)
    
19. {
    
20.         queue->size = pconfig->socket_number;
    
21.         queue->base = (int*)malloc(sizeof(int)*pconfig->socket_number);
    
22.         queue->writer  = HEAD;
    
23.         queue->reader  = HEAD - 1;
    
24. }
    
25. 
    
26. int enqueue(apr_socket_queue *queue,int socket)
    
27. {
    
28.         if(queue->writer+1 != queue->reader && queue->writer < queue->size-1)
    
29.         {
    
30.                 queue->base[queue->writer] = socket;
    
31.                 queue->writer++;
    
32.                 return TRUE;
    
33.         }
    
34. 
    
35.         if(queue->writer == queue->size-1 && queue->reader > HEAD)
    
36.         {
    
37.                 queue->base[queue->writer] = socket;
    
38.                 queue->writer = HEAD;
    
39.                 return TRUE;
    
40.         }
    
41. 
    
42.         return FALSE;//the queue is full
    
43. }
    
44. 
    
45. int dequeue(apr_socket_queue *queue,int *socket)
    
46. {
    
47.         if(queue->reader+1 != queue->writer && queue->reader < queue->size-1)
    
48.         {
    
49.                 queue->reader++;
    
50.                 *socket = queue->base[queue->reader];
    
51.                 return TRUE;
    
52.         }
    
53. 
    
54.         if(queue->reader == queue->size-1 && queue->writer > HEAD)
    
55.         {
    
56.                 queue->reader = HEAD;
    
57.                 *socket = queue->base[queue->reader];
    
58.                 return TRUE;
    
59.         }
    
60. 
    
61.         return FALSE;// the queue is empty
    
62. }
    
63. 
    
64. 
    
65. void destroy_queue(apr_socket_queue *queue)
    
66. {
    
67.         free(queue->base);
    
68.         queue->writer = HEAD;
    
69.         queue->reader = HEAD -1;
    
70.         queue->size = 0;
    
71. }
    
72. 
    

复制代码

iCoding

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

wenkai169

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

pdsxw123

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

iCoding

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

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

wenkai169

加锁只多消耗10%性能，为啥不加锁呢？

iCoding

t起

iCoding

go on

happyforest

这个是有问题的,  始终都有一个节点读不出来, 就是writer最后一次写的节点.

happyforest

不好意思, 看错了, 是对的.....