From 37eeef3f23b7c22a6a454a6a31a1369919ac197f Mon Sep 17 00:00:00 2001
From: yuqing <qing.yu@yundongpai.net>
Date: Tue, 12 Jun 2018 16:49:12 +0800
Subject: [PATCH] common_blocked_queue_terminate with count

---
 src/common_blocked_queue.h | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/src/common_blocked_queue.h b/src/common_blocked_queue.h
index df2c6bf..2a91403 100644
--- a/src/common_blocked_queue.h
+++ b/src/common_blocked_queue.h
@@ -45,9 +45,13 @@ int common_blocked_queue_init_ex(struct common_blocked_queue *queue,
 
 void common_blocked_queue_destroy(struct common_blocked_queue *queue);
 
-static inline void common_blocked_queue_terminate(struct common_blocked_queue *queue)
+static inline void common_blocked_queue_terminate(struct common_blocked_queue *queue, const int count)
 {
-     pthread_cond_signal(&(queue->cond));
+    int i;
+    for (i=0; i<count; i++)
+    {
+        pthread_cond_signal(&(queue->cond));
+    }
 }
 
 int common_blocked_queue_push(struct common_blocked_queue *queue, void *data);