| 0,0 → 1,23 |
|---|
| /* Create a new thread pool with n threads. */ |
| struct thread_pool * thread_pool_new(int nthreads); |
| |
| /* Shutdown this thread pool. May or may not execute already queued tasks. */ |
| void thread_pool_shutdown(struct thread_pool *); |
| |
| /* A function pointer representing a 'callable' */ |
| typedef void * (* thread_pool_callable_func_t) (void * data); |
| |
| /* Submit a callable to thread pool and return future. |
| * The returned future can be used in future_get() and future_free() |
| */ |
| struct future * thread_pool_submit( |
| struct thread_pool *, |
| thread_pool_callable_func_t callable, |
| void * callable_data); |
| |
| /* Make sure that thread pool has completed executing this callable, |
| * then return result. */ |
| void * future_get(struct future *); |
| |
| /* Deallocate this future. Must be called after future_get() */ |
| void future_free(struct future *); |