diff options
Diffstat (limited to 'src/threadpool-shim.c')
| -rw-r--r-- | src/threadpool-shim.c | 195 |
1 files changed, 195 insertions, 0 deletions
diff --git a/src/threadpool-shim.c b/src/threadpool-shim.c new file mode 100644 index 0000000..c8ef51d --- /dev/null +++ b/src/threadpool-shim.c @@ -0,0 +1,195 @@ +/* Standard C headers */ +#include <stddef.h> + +/* Library header */ +#include <pthreadpool.h> + +static inline size_t min(size_t a, size_t b) { + return a < b ? a : b; +} + +struct pthreadpool* pthreadpool_create(size_t threads_count) { + return NULL; +} + +size_t pthreadpool_get_threads_count(struct pthreadpool* threadpool) { + return 1; +} + +void pthreadpool_parallelize_1d( + struct pthreadpool* threadpool, + pthreadpool_task_1d_t task, + void* argument, + size_t range, + uint32_t flags) +{ + for (size_t i = 0; i < range; i++) { + task(argument, i); + } +} + +void pthreadpool_parallelize_1d_tile_1d( + pthreadpool_t threadpool, + pthreadpool_task_1d_tile_1d_t task, + void* argument, + size_t range, + size_t tile, + uint32_t flags) +{ + for (size_t i = 0; i < range; i += tile) { + task(argument, i, min(range - i, tile)); + } +} + +void pthreadpool_parallelize_2d( + struct pthreadpool* threadpool, + pthreadpool_task_2d_t task, + void* argument, + size_t range_i, + size_t range_j, + uint32_t flags) +{ + for (size_t i = 0; i < range_i; i++) { + for (size_t j = 0; j < range_j; j++) { + task(argument, i, j); + } + } +} + +void pthreadpool_parallelize_2d_tile_1d( + pthreadpool_t threadpool, + pthreadpool_task_2d_tile_1d_t task, + void* argument, + size_t range_i, + size_t range_j, + size_t tile_j, + uint32_t flags) +{ + for (size_t i = 0; i < range_i; i++) { + for (size_t j = 0; j < range_j; j += tile_j) { + task(argument, i, j, min(range_j - j, tile_j)); + } + } +} + +void pthreadpool_parallelize_2d_tile_2d( + pthreadpool_t threadpool, + pthreadpool_task_2d_tile_2d_t task, + void* argument, + size_t range_i, + size_t range_j, + size_t tile_i, + size_t tile_j, + uint32_t flags) +{ + for (size_t i = 0; i < range_i; i += tile_i) { + for (size_t j = 0; j < range_j; j += tile_j) { + task(argument, i, j, min(range_i - i, tile_i), min(range_j - j, tile_j)); + } + } +} + +void pthreadpool_parallelize_3d_tile_2d( + pthreadpool_t threadpool, + pthreadpool_task_3d_tile_2d_t task, + void* argument, + size_t range_i, + size_t range_j, + size_t range_k, + size_t tile_j, + size_t tile_k, + uint32_t flags) +{ + for (size_t i = 0; i < range_i; i++) { + for (size_t j = 0; j < range_j; j += tile_j) { + for (size_t k = 0; k < range_k; k += tile_k) { + task(argument, i, j, k, + min(range_j - j, tile_j), min(range_k - k, tile_k)); + } + } + } +} + +void pthreadpool_parallelize_4d_tile_2d( + pthreadpool_t threadpool, + pthreadpool_task_4d_tile_2d_t task, + void* argument, + size_t range_i, + size_t range_j, + size_t range_k, + size_t range_l, + size_t tile_k, + size_t tile_l, + uint32_t flags) +{ + for (size_t i = 0; i < range_i; i++) { + for (size_t j = 0; j < range_j; j++) { + for (size_t k = 0; k < range_k; k += tile_k) { + for (size_t l = 0; l < range_l; l += tile_l) { + task(argument, i, j, k, l, + min(range_k - k, tile_k), min(range_l - l, tile_l)); + } + } + } + } +} + +void pthreadpool_parallelize_5d_tile_2d( + pthreadpool_t threadpool, + pthreadpool_task_5d_tile_2d_t task, + void* argument, + size_t range_i, + size_t range_j, + size_t range_k, + size_t range_l, + size_t range_m, + size_t tile_l, + size_t tile_m, + uint32_t flags) +{ + for (size_t i = 0; i < range_i; i++) { + for (size_t j = 0; j < range_j; j++) { + for (size_t k = 0; k < range_k; k++) { + for (size_t l = 0; l < range_l; l += tile_l) { + for (size_t m = 0; m < range_m; m += tile_m) { + task(argument, i, j, k, l, m, + min(range_l - l, tile_l), min(range_m - m, tile_m)); + } + } + } + } + } +} + +void pthreadpool_parallelize_6d_tile_2d( + pthreadpool_t threadpool, + pthreadpool_task_6d_tile_2d_t task, + void* argument, + size_t range_i, + size_t range_j, + size_t range_k, + size_t range_l, + size_t range_m, + size_t range_n, + size_t tile_m, + size_t tile_n, + uint32_t flags) +{ + for (size_t i = 0; i < range_i; i++) { + for (size_t j = 0; j < range_j; j++) { + for (size_t k = 0; k < range_k; k++) { + for (size_t l = 0; l < range_l; l++) { + for (size_t m = 0; m < range_m; m += tile_m) { + for (size_t n = 0; n < range_n; n += tile_n) { + task(argument, i, j, k, l, m, n, + min(range_m - m, tile_m), min(range_n - n, tile_n)); + } + } + } + } + } + } +} + +void pthreadpool_destroy(struct pthreadpool* threadpool) { +} |