在坛子里找到的线程安全的队列代码，咋用？？？

jd808

1. 
   
2. #include <pthread.h>
   
3. #include <iostream>
   
4. #include <queue>
   
5. 
   
6. #define QUEUESIZE 10
   
7. 
   
8. template <class Object>
   
9. class ThreadQueue {
   
10.         private:
    
11.                 std::queue <Object> que;
    
12.                 int size;
    
13.                 pthread_mutex_t mutex;
    
14. 
    
15.         public:
    
16.                 ThreadQueue();
    
17.                 ~ThreadQueue();
    
18. 
    
19.         public:
    
20.                 bool IsEmpty() const;
    
21.                 void Push(const Object &obj);
    
22.                 void Pop();
    
23.                 int Count() const;
    
24.                 Object& Front();
    
25.                 Object& Back();
    
26.                 void Clear();
    
27. };
    
28. 
    
29. class UserSendCache {
    
30.         private:
    
31. 
    
32. 
    
33.         public:
    
34.                 UserSendCache();
    
35.                 ~UserSendCache();
    
36. 
    
37.         public:
    
38. 
    
39. };
    
40. 
    
41. 
    
42. 
    
43. template <class Object>
    
44. ThreadQueue<Object>::ThreadQueue()
    
45. {
    
46.     pthread_mutex_init(&mutex, NULL);
    
47.     size = 0;
    
48. }
    
49. 
    
50. template <class Object>
    
51. ThreadQueue<Object>::~ThreadQueue()
    
52. {
    
53.     pthread_mutex_destroy(&mutex);
    
54. }
    
55. 
    
56. template <class Object>
    
57. bool ThreadQueue<Object>::IsEmpty() const
    
58. {
    
59.     if(size == 0)
    
60.         return true;
    
61.     else
    
62.         return false;
    
63. }
    
64. 
    
65. //从队列尾部添加数据
    
66. template <class Object>
    
67. void ThreadQueue<Object>::Push(const Object &obj)
    
68. {
    
69.     pthread_mutex_lock(&mutex);
    
70.     if(que.size()==QUEUESIZE){//已经满了，删除最开始那个，然后在加入,保证队列始终不超过QUEUESIZE
    
71.             que.pop();
    
72.     }
    
73. 
    
74.     que.push(obj);
    
75.     size = que.size();
    
76.     pthread_mutex_unlock(&mutex);
    
77. }
    
78. 
    
79. //队列头部数据出队
    
80. template <class Object>
    
81. void ThreadQueue<Object>::Pop()
    
82. {
    
83.     pthread_mutex_lock(&mutex);
    
84.     que.pop();
    
85.     size = que.size();
    
86.     pthread_mutex_unlock(&mutex);
    
87. }
    
88. 
    
89. template <class Object>
    
90. int ThreadQueue<Object>::Count() const
    
91. {
    
92.     return(size);
    
93. }
    
94. 
    
95. //返回队列头部数据
    
96. template <class Object>
    
97. Object& ThreadQueue<Object>::Front()
    
98. {
    
99.     pthread_mutex_lock(&mutex);
    
100.     Object &obj = que.front();
     
101.     pthread_mutex_unlock(&mutex);
     
102.     return obj;
     
103. }
     
104. 
     
105. //返回队列尾部数据
     
106. template <class Object>
     
107. Object& ThreadQueue<Object>::Back()
     
108. {
     
109.     pthread_mutex_lock(&mutex);
     
110.     Object &obj = que.back();
     
111.     pthread_mutex_unlock(&mutex);
     
112.     return obj;
     
113. }
     
114. 
     
115. template <class Object>
     
116. void ThreadQueue<Object>::Clear()
     
117. {
     
118.     pthread_mutex_lock(&mutex);
     
119.     while (!que.empty())
     
120.     {
     
121.       que.pop();
     
122.     }
     
123.     size = 0;
     
124.     pthread_mutex_unlock(&mutex);
     
125. }
     
126. 
     
127. int main()
     
128. {
     
129. //      ThreadQueue<UserSendCache> t = new ThreadQueue<UserSendCache>();//这个也不行
     
130.         ThreadQueue<UserSendCache> t();
     
131.         const UserSendCache* d = new UserSendCache();
     
132.         t.Push(d);
     
133.     return 0;
     
134. }
     

复制代码

在坛里找到了这个队列代码，咋用？
ThreadQueue<UserSendCache> t = new ThreadQueue<UserSendCache>();
用这个代码编译直接报
/usr/include/c++/5/bits/stl_construct.h:93：对‘UserSendCache::~UserSendCache()’未定义的引用
/usr/include/c++/5/bits/stl_construct.h:93：对‘UserSendCache::~UserSendCache()’未定义的引用
/usr/include/c++/5/bits/stl_construct.h:93：对‘UserSendCache::~UserSendCache()’未定义的引用
/usr/include/c++/5/bits/stl_construct.h:93：对‘UserSendCache::~UserSendCache()’未定义的引用
/usr/include/c++/5/bits/stl_construct.h:93：对‘UserSendCache::~UserSendCache()’未定义的引用
gateway/src/ThreadQueue.o:/usr/include/c++/5/bits/stl_construct.h:93: 跟着更多未定义的参考到 UserSendCache::~UserSendCache()
collect2: error: ld returned 1 exit status

用这个ThreadQueue<UserSendCache> t();
报
error: request for member ‘Push’ in ‘t’, which is of non-class type ‘ThreadQueue<UserSendCache>()’

littledick

吐槽不能。

jd808

不会用模板呀，没人告诉我？

jd808

哎，注意到了，原来少了UserSendCache的构造和析构，开始以为是ThreadQueue少了，看代码又有，搞得我折腾了半天

jd808

话说，这么明显的，坛子里也没人帮忙看下，有时候钻进去一下子出不来～～～～