pdxx
/
libfastcommon
mirror of https://github.com/happyfish100/libfastcommon.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

common_blocked_queue_terminate with count

pull/37/head
yuqing 2018-06-12 16:49:12 +08:00
parent 571be969dd
commit 37eeef3f23
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/common_blocked_queue.h
View File

@ -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); 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); int common_blocked_queue_push(struct common_blocked_queue *queue, void *data);