Mercurial > foo_out_sdl
diff foosdk/sdk/foobar2000/SDK/threadPool.h @ 1:20d02a178406 default tip
*: check in everything else
yay
| author | Paper <paper@tflc.us> |
|---|---|
| date | Mon, 05 Jan 2026 02:15:46 -0500 |
| parents | |
| children |
line wrap: on
line diff
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/foosdk/sdk/foobar2000/SDK/threadPool.h Mon Jan 05 02:15:46 2026 -0500 @@ -0,0 +1,36 @@ +#pragma once + +#include <functional> +namespace fb2k { + void inWorkerThread(std::function<void()> f); + void inCpuWorkerThread(std::function<void()> f); + + //! \since 2.0 + class threadEntry : public service_base { + FB2K_MAKE_SERVICE_INTERFACE(threadEntry, service_base); + public: + virtual void run() = 0; + + static threadEntry::ptr make(std::function<void()> f); + }; + + //! \since 2.0 + //! A class interfacing with shared pool of threads intended for use with CPU bound tasks. \n + //! Use this instead of creating threads directly to avoid making the system unresponsive by creating too many CPU bound threads. + class cpuThreadPool : public service_base { + FB2K_MAKE_SERVICE_COREAPI(cpuThreadPool); + public: + //! Run one time task on a thread pool. Returns immediately. + virtual void runSingle(threadEntry::ptr trd) = 0; + //! Run the task multiple times concurrently. Optionally block until all done. \n + //! Exceptions: if nonblocking, they're discarded; if blocking; rethrown to caller. If multiple are thrown, one of them is rethrown, precedence undefined. + virtual void runMulti(threadEntry::ptr trd, size_t numRuns, bool blocking) = 0; + + virtual size_t numRunsSanity(size_t suggested) = 0; + + //! Helper around blocking runMulti(), with fallback for pre-v2.0 + static void runMultiHelper(std::function<void()>, size_t numRuns); + void runMulti_(std::function<void()>, size_t numRuns); + }; +} +
