在壇子里找到的線程安全的隊列代碼，咋用？？？

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. //從隊列尾部添加數(shù)據(jù)
    
66. template <class Object>
    
67. void ThreadQueue<Object>::Push(const Object &obj)
    
68. {
    
69.     pthread_mutex_lock(&mutex);
    
70.     if(que.size()==QUEUESIZE){//已經(jīng)滿了，刪除最開始那個，然后在加入,保證隊列始終不超過QUEUESIZE
    
71.             que.pop();
    
72.     }
    
73. 
    
74.     que.push(obj);
    
75.     size = que.size();
    
76.     pthread_mutex_unlock(&mutex);
    
77. }
    
78. 
    
79. //隊列頭部數(shù)據(jù)出隊
    
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. //返回隊列頭部數(shù)據(jù)
    
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. //返回隊列尾部數(shù)據(jù)
     
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. }
     

復(fù)制代碼

在壇里找到了這個隊列代碼，咋用？
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的構(gòu)造和析構(gòu)，開始以為是ThreadQueue少了，看代碼又有，搞得我折騰了半天

jd808

話說，這么明顯的，壇子里也沒人幫忙看下，有時候鉆進去一下子出不來～～～～