-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy paththreadpool.h
36 lines (27 loc) · 1.06 KB
/
threadpool.h
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
#ifndef THREAD_POOL_H
#define THREAD_POOL_H
#include <pthread.h>
typedef struct {
int client_fd;
char *buffer;
} TaskArgs;
typedef void (*FunctionPointer)(TaskArgs*);
typedef struct {
FunctionPointer function; // Ponteiro para a função
void* argument; // Argumento da função
} Task;
// Estrutura para o pool de threads
typedef struct {
Task* tasks; // Fila de tarefas
int task_count; // Número de tarefas na fila
int head, tail; // Ponteiros para início e fim da fila
int queue_size; // Tamanho da fila
pthread_mutex_t lock; // Mutex para sincronização
pthread_cond_t notify; // Condição para notificação
int shutdown; // Flag para finalizar o pool
} ThreadPool;
//int thread_pool_add(ThreadPool* pool, void (*function)(void*), void* argument);
int thread_pool_add(ThreadPool* pool, FunctionPointer TaskFunc, void* argument);
void thread_pool_init(ThreadPool* pool, int thread_count, int queue_size);
void thread_pool_destroy(ThreadPool* pool);
#endif