diff --git a/src/ckpool.c b/src/ckpool.c
index 70725e08..218139de 100644
--- a/src/ckpool.c
+++ b/src/ckpool.c
@@ -175,7 +175,7 @@ ckmsgq_t *create_ckmsgqs(ckpool_t *ckp, const char *name, const void *func, cons
 }
 
 /* Generic function for adding messages to a ckmsgq linked list and signal the
- * ckmsgq parsing thread to wake up and process it. */
+ * ckmsgq parsing thread(s) to wake up and process it. */
 void ckmsgq_add(ckmsgq_t *ckmsgq, void *data)
 {
 	ckmsg_t *msg = ckalloc(sizeof(ckmsg_t));
@@ -185,7 +185,7 @@ void ckmsgq_add(ckmsgq_t *ckmsgq, void *data)
 	mutex_lock(ckmsgq->lock);
 	ckmsgq->messages++;
 	DL_APPEND(ckmsgq->msgs, msg);
-	pthread_cond_signal(ckmsgq->cond);
+	pthread_cond_broadcast(ckmsgq->cond);
 	mutex_unlock(ckmsgq->lock);
 }