include/razorback/thread_pool.h

Go to the documentation of this file.

#ifndef RAZORBACK_THREAD_POOL_H
#define RAZORBACK_THREAD_POOL_H

#include <razorback/visibility.h>
#include <razorback/types.h>
#include <razorback/api.h>
#include <razorback/list.h>

#ifdef __cplusplus
extern "C" {
#endif
struct ThreadPool;
struct ThreadPoolItem
{
    struct Thread *thread;              
    int id;                                             
    struct ThreadPool *pool;    
};

struct ThreadPool
{
    size_t limit;                           
    int nextId;                             
    struct RazorbackContext *context;       
    void (*mainFunction) (struct Thread *); 
    const char *namePattern;                
    struct List *list;                                          
};

SO_PUBLIC extern struct ThreadPool *
ThreadPool_Create(int initialThreads, int maxThreads, struct RazorbackContext *context, const char* namePattern, void (*mainFunction) (struct Thread *));

SO_PUBLIC extern bool
ThreadPool_LaunchWorker(struct ThreadPool *pool);

SO_PUBLIC extern bool
ThreadPool_LaunchWorkers(struct ThreadPool *pool, int count);

SO_PUBLIC extern bool
ThreadPool_KillWorker(struct ThreadPool *pool, int id);

SO_PUBLIC extern bool
ThreadPool_KillWorkers(struct ThreadPool *pool);

#ifdef __cplusplus
}
#endif
#endif // RAZORBACK_THREAD_POOL_H

---