diff options
Diffstat (limited to 'src/script/cpp_api/s_async.h')
| -rw-r--r-- | src/script/cpp_api/s_async.h | 14 |
1 files changed, 6 insertions, 8 deletions
diff --git a/src/script/cpp_api/s_async.h b/src/script/cpp_api/s_async.h index 1dc4145ba..b1f4bf45f 100644 --- a/src/script/cpp_api/s_async.h +++ b/src/script/cpp_api/s_async.h @@ -31,6 +31,7 @@ with this program; if not, write to the Free Software Foundation, Inc., // Forward declarations class AsyncEngine; + // Declarations // Data required to queue a job @@ -51,10 +52,9 @@ struct LuaJobInfo }; // Asynchronous working environment -class AsyncWorkerThread : public Thread, public ScriptApiBase -{ +class AsyncWorkerThread : public Thread, public ScriptApiBase { public: - AsyncWorkerThread(AsyncEngine *jobDispatcher, const std::string &name); + AsyncWorkerThread(AsyncEngine* jobDispatcher, const std::string &name); virtual ~AsyncWorkerThread(); void *run(); @@ -64,11 +64,9 @@ private: }; // Asynchornous thread and job management -class AsyncEngine -{ +class AsyncEngine { friend class AsyncWorkerThread; typedef void (*StateInitializer)(lua_State *L, int top); - public: AsyncEngine() = default; ~AsyncEngine(); @@ -127,7 +125,7 @@ protected: * @param L Lua stack to initialize * @param top Stack position */ - void prepareEnvironment(lua_State *L, int top); + void prepareEnvironment(lua_State* L, int top); private: // Variable locking the engine against further modification @@ -151,7 +149,7 @@ private: std::deque<LuaJobInfo> resultQueue; // List of current worker threads - std::vector<AsyncWorkerThread *> workerThreads; + std::vector<AsyncWorkerThread*> workerThreads; // Counter semaphore for job dispatching Semaphore jobQueueCounter; |