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);