- 使用普通的队列代替自旋锁队列，因为在单线程中没有并发问题，且使用自旋锁可能会浪费CPU时间。
- 在生产者线程中使用 usleep 使得线程休眠一段时间，避免无限制地不停地往队列中添加元素，造成队列过度膨胀。
- 在消费者线程中使用 while 循环等待队列中有新的元素，而不是直接退出循环，以保证可以实时处理新加入队列的元素。
- 使用智能指针来管理内存，避免手动释放内存带来的问题。
代码如下：
#include
using namespace std;
template
typedef typename std::queue<T, Container> queue_t;typedef typename queue_t::value_type value_type;
protected:
queue_t m_queue;
public:
void push(const value_type& value){ m_queue.push(value);}bool try_pop(value_type& result){if (!m_queue.empty()){result = m_queue.front();m_queue.pop();return true;}elsereturn false;}
};
struct ttt {
char a[12];int b;
};
static terra_queuestd::shared_ptr<ttt> global_queue;
void* workTrheadFunc(void* arg) {
int v=0;while (true){ttt *val=new ttt;val->b=v++;global_queue.push(std::shared_ptr<ttt>(val));usleep(100); // 休眠一段时间}return 0;
}
int main() {
pthread_t log_tid;pthread_attr_t attr;pthread_attr_init(&attr);const size_t stack_size = 10 * 1024 * 1024 * 1024;pthread_attr_setstacksize(&attr, stack_size);pthread_create(&log_tid, &attr, workTrheadFunc,NULL);while (true){std::shared_ptr<ttt> i;while (!global_queue.try_pop(i)) {} // 等待有元素可以处理cout << "Consumer: " << i->b << endl;}
}
