lockfree-list C++11 atomic<T> 编译不过，求教@_@

lxyscls

之前的enqueue有问题

http://bbs.chinaunix.net/thread-4187093-1-1.html

现在这个编译都不过

一楼free-list代码

1. #ifndef __FREELIST_HPP__
   
2. #define __FREELIST_HPP__
   
3. 
   
4. #include <cstdlib>
   
5. #include <atomic>
   
6. 
   
7. #define DUMMY -1
   
8. 
   
9. using namespace std;
   
10. 
    
11. template <typename T> class list;
    
12. template <typename T>
    
13. class item {
    
14.         friend class list<T>;
    
15.         private:
    
16.                 item(const T &t) : data(t) { next.store(NULL); }
    
17.                 T data;
    
18.                 atomic<item<T> *> next;
    
19. };
    
20. 
    
21. template <typename T>
    
22. class list {
    
23.         public:
    
24.                 list();
    
25.                 void Enqueue(const T&);
    
26.                 T Dequeue(void);
    
27.         private:
    
28.                 atomic<item<T> *> head;
    
29.                 atomic<item<T> *> tail;
    
30. };
    
31. 
    
32. template <typename T>
    
33. list<T>::list()
    
34. {
    
35.         item<T> *i = new item<T>(DUMMY);
    
36.         head.store(i);
    
37.         tail.store(i);
    
38. }
    
39. 
    
40. template <typename T>
    
41. void list<T>::Enqueue(const T &t)
    
42. {
    
43.         item<T> *p, *q = new item<T>(t);
    
44. 
    
45.         do {
    
46.                 p = tail.load();
    
47.         } while (p->next.compare_exchange_weak((item<T> *)NULL, q) != true);
    
48. 
    
49.         tail.compare_exchange_weak(p, q);
    
50. }
    
51. 
    
52. template <typename T>
    
53. T list<T>::Dequeue(void)
    
54. {
    
55.         item<T> *p, *q;
    
56. 
    
57.         do {
    
58.                 p = head.load();
    
59.                 q = p->next.load();
    
60.                 if (q == NULL)
    
61.                         return DUMMY;
    
62.         } while (head.compare_exchange_weak(p, q) != true);
    
63. 
    
64.         return q->data;
    
65. }
    
66. 
    
67. #endif

复制代码

lxyscls

二楼测试代码

1. #include <thread>
   
2. #include <iostream>
   
3. 
   
4. #include "freelist.hpp"
   
5. 
   
6. using namespace std;
   
7. 
   
8. list<int> fl;
   
9. thread **prod_threads;
   
10. thread **cons_threads;
    
11. 
    
12. #define CNT 1000
    
13. 
    
14. void producer(void)
    
15. {
    
16.         for (int i = 0; i < CNT; i++) {
    
17.                 fl.Enqueue(i);
    
18.         }
    
19. }
    
20. 
    
21. void consumer(void)
    
22. {
    
23.         int ret, i = 0;
    
24. 
    
25.         while (1) {
    
26.                 ret = fl.Dequeue();
    
27.                 if (ret != DUMMY) {
    
28.                         cout << ret << endl;
    
29.                         if (++i == CNT)
    
30.                                 break;
    
31.                 }
    
32.         }
    
33. }
    
34. 
    
35. int main(int argc, char *argv[])
    
36. {
    
37.         int prod_num = atoi(argv[1]);
    
38.         int cons_num = atoi(argv[2]);
    
39. 
    
40.         prod_threads = new thread *[prod_num];
    
41.         cons_threads = new thread *[cons_num];
    
42. 
    
43.         for (int i = 0; i < prod_num; i++)
    
44.                 prod_threads[i] = new thread(producer);
    
45. 
    
46.         for (int i = 0; i < cons_num; i++)
    
47.                 cons_threads[i] = new thread(consumer);
    
48. 
    
49.         for (int i = 0; i < prod_num; i++) {
    
50.                 prod_threads[i]->join();
    
51.                 delete prod_threads[i];
    
52.         }
    
53. 
    
54.         for (int i = 0; i< cons_num; i++) {
    
55.                 cons_threads[i]->join();
    
56.                 delete cons_threads[i];
    
57.         }
    
58. 
    
59.         delete [] prod_threads;
    
60.         delete [] cons_threads;
    
61. 
    
62.         return 0;
    
63. }

复制代码

windoze

当我看见了“4.7”的时候就懒得再看下去了，你先把那个3岁多的编译器升级到4.9/5.x再来研究这个问题吧。

lxyscls

回复 3# windoze


    问题还是那个问题，p->next.compare_exchange_weak((item<T> *)NULL, q)
   
    是这个NULL的问题，原来是C++不提供空引用

    使用#define NULLRef(type) (*((type*)(NULL)))，p->next.compare_exchange_weak(NULLRef(item<T> *), q)就可以了

    补充一下：atomic函数里面需要查看该地址的值，所以这样也是不行的，需要引入哑元，凸