thread_pool.h

Go to the documentation of this file.

#pragma once
 
#include <stdint.h>
#include <stdbool.h>
#include "common.h"
#include "platform/abstraction.h"
 
// Forward declaration
typedef struct thread_pool thread_pool_t;
typedef struct thread_pool_entry thread_pool_entry_t;
 
struct thread_pool_entry {
  asciichat_thread_t thread;      
  int stop_id;                    
  void *(*thread_func)(void *);   
  void *thread_arg;               
  char name[64];                  
  struct thread_pool_entry *next; 
};
 
struct thread_pool {
  char name[64];                
  thread_pool_entry_t *threads; 
  mutex_t threads_mutex;        
  size_t thread_count;          
};
 
thread_pool_t *thread_pool_create(const char *pool_name);
 
void thread_pool_destroy(thread_pool_t *pool);
 
asciichat_error_t thread_pool_spawn(thread_pool_t *pool, void *(*thread_func)(void *), void *thread_arg, int stop_id,
                                    const char *thread_name);
 
asciichat_error_t thread_pool_stop_all(thread_pool_t *pool);
 
size_t thread_pool_get_count(const thread_pool_t *pool);
 
bool thread_pool_has_threads(const thread_pool_t *pool);