Update BlockingQueue.ixx

Author: masx200

print-foobar-alternately/BlockingQueue.ixx

@@ -1,21 +1,23 @@
 module;
+#include <climits>
+#include <condition_variable>
 #include <functional>
 #include <mutex>
 #include <queue>
+
 export module leetcode_test.print_foobar_alternately.BlockingQueue;
 using namespace std;
 namespace leetcode_test::print_foobar_alternately {
 
-export template <class E>
-class BlockingQueue {
+export template <class E> class BlockingQueue {
 
-private:
+  private:
     queue<E> _queue;
     int capacity = INT_MAX;
     condition_variable takeVariable, putVariable;
     mutable mutex lock;
 
-public:
+  public:
     BlockingQueue();
     /**
      *
@@ -27,13 +29,13 @@ public:
      * @param e
      * @return -1失败, 0成功
      */
-    int take(E& e);
+    int take(E &e);
     /**
      * size >= capacity时会阻塞
      * @param e
      * @return
      */
-    int put(const E& e);
+    int put(const E &e);
 
     bool empty() const;
 
@@ -46,18 +48,12 @@ public:
     E front();
 };
 
-template <class E>
-BlockingQueue<E>::BlockingQueue() { }
+template <class E> BlockingQueue<E>::BlockingQueue() {}
 
 template <class E>
-BlockingQueue<E>::BlockingQueue(int capacity)
-    : capacity(capacity)
-{
-}
+BlockingQueue<E>::BlockingQueue(int capacity) : capacity(capacity) {}
 
-template <class E>
-int BlockingQueue<E>::take(E& e)
-{
+template <class E> int BlockingQueue<E>::take(E &e) {
     unique_lock<mutex> uniqueLock(lock);
     while (_queue.empty()) {
         takeVariable.wait(uniqueLock);
@@ -70,9 +66,7 @@ int BlockingQueue<E>::take(E& e)
     return 0;
 }
 
-template <class E>
-int BlockingQueue<E>::put(const E& e)
-{
+template <class E> int BlockingQueue<E>::put(const E &e) {
     unique_lock<mutex> uniqueLock(lock);
     while (_queue.size() >= capacity) {
         putVariable.wait(uniqueLock);
@@ -84,38 +78,28 @@ int BlockingQueue<E>::put(const E& e)
     return 0;
 }
 
-template <class E>
-bool BlockingQueue<E>::empty() const
-{
+template <class E> bool BlockingQueue<E>::empty() const {
     lock_guard<mutex> lockGuard(lock);
     return _queue.empty();
 }
 
-template <class E>
-unsigned int BlockingQueue<E>::size() const
-{
+template <class E> unsigned int BlockingQueue<E>::size() const {
     lock_guard<mutex> lockGuard(lock); // 利用变量作用域创建加锁,析构自动解锁
     return _queue.size();
 }
 
-template <class E>
-void BlockingQueue<E>::pop()
-{
+template <class E> void BlockingQueue<E>::pop() {
     lock.lock();
     _queue.pop();
     lock.unlock();
 }
 
-template <class E>
-E BlockingQueue<E>::back()
-{
+template <class E> E BlockingQueue<E>::back() {
     lock_guard<mutex> lockGuard(lock);
     return _queue.back();
 }
 
-template <class E>
-E BlockingQueue<E>::front()
-{
+template <class E> E BlockingQueue<E>::front() {
     lock_guard<mutex> lockGuard(lock);
     return _queue.front();
 }