asyncqueue.h

Go to the documentation of this file.

/***************************************************************************
    begin........: June 2012
    copyright....: Sebastian Fedrau
    email........: sebastian.fedrau@gmail.com
 ***************************************************************************/
 
/***************************************************************************
    This program is free software; you can redistribute it and/or modify
    it under the terms of the GNU General Public License v3 as published by
    the Free Software Foundation.
 
    This program is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
    General Public License v3 for more details.
 ***************************************************************************/
#ifdef WITH_PTHREAD
 
#ifndef ASYNCQUEUE_H
#define ASYNCQUEUE_H
 
#include <pthread.h>
 
#include "datatypes.h"
 
typedef struct
{
    pthread_mutex_t mutex;
    pthread_cond_t cond;
    Queue queue;
    size_t waiting;
} AsyncQueue;
 
AsyncQueue *async_queue_new(CompareFunc compare, FreeFunc free, Pool *pool);
 
void async_queue_init(AsyncQueue *queue, CompareFunc compare, FreeFunc free, Pool *pool);
 
void async_queue_destroy(AsyncQueue *queue);
 
void async_queue_free(AsyncQueue *queue);
 
void async_queue_push(AsyncQueue *queue, void *data);
 
bool async_queue_pop(AsyncQueue *queue, void *data);
 
bool async_queue_pop_timeout(AsyncQueue *queue, void *data, uint32_t ms);
 
void async_queue_clear(AsyncQueue *queue);
 
size_t async_queue_count(AsyncQueue *queue);
 
#endif /* __ASYNCQUEUE_H__ */
 
#endif /* WITH_PTHREAD */