Browse Source

Support shutdown with postLimit in BlockingQueue

Adam Ierymenko 6 years ago
parent
commit
690bd933d5
1 changed files with 3 additions and 0 deletions
  1. 3 0
      osdep/BlockingQueue.hpp

+ 3 - 0
osdep/BlockingQueue.hpp

@@ -63,6 +63,8 @@ public:
 				c.notify_one();
 				c.notify_one();
 				break;
 				break;
 			}
 			}
+			if (!r)
+				break;
 			gc.wait(lock);
 			gc.wait(lock);
 		}
 		}
 	}
 	}
@@ -72,6 +74,7 @@ public:
 		std::lock_guard<std::mutex> lock(m);
 		std::lock_guard<std::mutex> lock(m);
 		r = false;
 		r = false;
 		c.notify_all();
 		c.notify_all();
+		gc.notify_all();
 	}
 	}
 
 
 	inline bool get(T &value)
 	inline bool get(T &value)