threadpool.h

Go to the documentation of this file.

 
#ifndef __THREADPOOL_H__
#define __THREADPOOL_H__
 
#include <semaphore.h>
#include <signal.h>
#include <stdbool.h>
#include <stddef.h>
 
typedef struct runnable {
  void (*function)(void *, size_t); 
  void *arg; 
  size_t argsz; 
} runnable_t;
 
typedef struct node {
    runnable_t runnable; 
    struct node* next; 
} node_t;
 
typedef struct queue {
    node_t* first; 
    node_t* last;  
    size_t size;   
} queue_t;
 
typedef struct thread_pool {
    size_t pool_size; 
    sem_t mutex; 
    sem_t waiting_threads; 
    queue_t* queue; 
    pthread_t* threads; 
    bool finished; 
    pthread_attr_t attr; 
} thread_pool_t;
 
int thread_pool_init(thread_pool_t *pool, size_t pool_size);
 
void thread_pool_destroy(thread_pool_t *pool);
 
int defer(thread_pool_t *pool, runnable_t runnable);
 
#endif // __THREADPOOL_H__