aboutsummaryrefslogtreecommitdiff
path: root/include/threadpool.h
diff options
context:
space:
mode:
authorDavid Oberhollenzer <david.oberhollenzer@sigma-star.at>2022-06-26 16:45:52 +0200
committerDavid Oberhollenzer <david.oberhollenzer@sigma-star.at>2022-07-08 19:17:35 +0200
commit2087cc237cd0fe1ed29ebf891648bacb46f4833b (patch)
treeede4ba232bea36d8fc670ce360514927a2400bc7 /include/threadpool.h
parentaed35c78c6a51a4b4c37ebda5643d2246842fb74 (diff)
Cleanup: move libutil headers to sub directory
Move all the libutil stuff from the toplevel include/ to a util/ sub directory and fix up the includes that make use of them. Signed-off-by: David Oberhollenzer <david.oberhollenzer@sigma-star.at>
Diffstat (limited to 'include/threadpool.h')
-rw-r--r--include/threadpool.h125
1 files changed, 0 insertions, 125 deletions
diff --git a/include/threadpool.h b/include/threadpool.h
deleted file mode 100644
index f25c497..0000000
--- a/include/threadpool.h
+++ /dev/null
@@ -1,125 +0,0 @@
-/* SPDX-License-Identifier: LGPL-3.0-or-later */
-/*
- * threadpool.h
- *
- * Copyright (C) 2021 David Oberhollenzer <goliath@infraroot.at>
- */
-#ifndef THREADPOOL_H
-#define THREADPOOL_H
-
-#include "sqfs/predef.h"
-
-typedef int (*thread_pool_worker_t)(void *user, void *work_item);
-
-/**
- * @struct thread_pool_t
- *
- * @brief A thread pool with a ticket number based work item ordering.
- *
- * While the order in which items are non-deterministic, the thread pool
- * implementation internally uses a ticket system to ensure the completed
- * items are deqeueued in the same order that they were enqueued.
- */
-typedef struct thread_pool_t {
- /**
- * @brief Shutdown and destroy a thread pool.
- *
- * @param pool A pointer to a pool returned by thread_pool_create
- */
- void (*destroy)(struct thread_pool_t *pool);
-
- /**
- * @brief Get the actual number of worker threads available.
- *
- * @return A number greater or equal to 1.
- */
- size_t (*get_worker_count)(struct thread_pool_t *pool);
-
- /**
- * @brief Change the user data pointer for a thread pool worker
- * by index.
- *
- * @param idx A zero-based index into the worker list.
- * @param ptr A user pointer that this specific worker thread should
- * pass to the worker callback.
- */
- void (*set_worker_ptr)(struct thread_pool_t *pool, size_t idx,
- void *ptr);
-
- /**
- * @brief Submit a work item to a thread pool.
- *
- * This function will fail on allocation failure or if the internal
- * error state is set was set by one of the workers.
- *
- * @param ptr A pointer to a work object to enqueue.
- *
- * @return Zero on success.
- */
- int (*submit)(struct thread_pool_t *pool, void *ptr);
-
- /**
- * @brief Wait for a work item to be completed.
- *
- * This function dequeues a single completed work item. It may block
- * until one of the worker threads signals completion of an additional
- * item.
- *
- * This function guarantees to return the items in the same order as
- * they were submitted, so the function can actually block longer than
- * necessary, because it has to wait until the next item in sequence
- * is finished.
- *
- * @return A pointer to a new work item or NULL if there are none
- * in the pipeline.
- */
- void *(*dequeue)(struct thread_pool_t *pool);
-
- /**
- * @brief Get the internal worker return status value.
- *
- * If the worker functions returns a non-zero exit status in one of the
- * worker threads, the thread pool stors the value internally and shuts
- * down. This function can be used to retrieve the value.
- *
- * @return A non-zero value returned by the worker callback or zero if
- * everything is A-OK.
- */
- int (*get_status)(struct thread_pool_t *pool);
-} thread_pool_t;
-
-#ifdef __cplusplus
-extern "C" {
-#endif
-
-/**
- * @brief Create a thread pool instance.
- *
- * @param num_jobs The number of worker threads to launch.
- * @param worker A function to call from the worker threads to process
- * the work items.
- *
- * @return A pointer to a thread pool on success, NULL on failure.
- */
-SQFS_INTERNAL thread_pool_t *thread_pool_create(size_t num_jobs,
- thread_pool_worker_t worker);
-
-/**
- * @brief Create a serial mockup thread pool implementation.
- *
- * This returns a @ref thread_pool_t implementation that, instead of running a
- * thread pool actually does the work in-situ when dequeueing.
- *
- * @param worker A function to call from the worker threads to process
- * the work items.
- *
- * @return A pointer to a thread pool on success, NULL on failure.
- */
-SQFS_INTERNAL
-thread_pool_t *thread_pool_create_serial(thread_pool_worker_t worker);
-
-#ifdef __cplusplus
-}
-#endif
-
-#endif /* THREADPOOL_H */