You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
47 lines
967 B
47 lines
967 B
10 months ago
|
# cthlib
|
||
|
|
## C threads helper lib
|
||
|
|
|
||
|
|
A small library to help with parallel function execution
|
||
|
|
|
||
|
|
## Functions
|
||
|
|
|
||
|
|
| Funcion | Description |
|
||
|
|
| --- | ----------- |
|
||
|
|
| `pool_t* pool_new` | Creates a new pool |
|
||
|
|
| `void pool_free(pool_t** pool)` | Frees up memory allocated to store a pool |
|
||
|
|
| `void pool_do(pool_t* pool, void* func, void* arg)` | Runs given function with arguments in parallel |
|
||
|
|
| `void pool_join(pool_t* pool)` | Waits for all parallel tasks to finish |
|
||
|
|
|
||
|
|
## Test example
|
||
|
|
|
||
|
|
```c
|
||
|
|
#include "../src/cthlib.h"
|
||
|
|
#include <threads.h>
|
||
|
|
#include <stdio.h>
|
||
|
|
#include <stdatomic.h>
|
||
|
|
|
||
|
|
|
||
|
|
void job(int* i) {
|
||
|
|
printf("start: %d\n", *i);
|
||
|
|
thrd_sleep(&(struct timespec){.tv_sec=2}, NULL);
|
||
|
|
*i = *i + 1;
|
||
|
|
printf("end: %d\n", *i);
|
||
|
|
}
|
||
|
|
|
||
|
|
atomic_int count = 0;
|
||
|
|
|
||
|
|
int main() {
|
||
|
|
pool_t* p = pool_new();
|
||
|
|
|
||
|
|
for (size_t i = 0; i < 5; i++) {
|
||
|
|
// Runs in parallel
|
||
|
|
pool_do(p, job, (void*) &count);
|
||
|
|
}
|
||
|
|
|
||
|
|
pool_join(p);
|
||
|
|
pool_free(&p);
|
||
|
|
}
|
||
|
|
```
|
||
|
|
|
||
|
|
## License
|
||
|
|
MIT
|