thijn/SqMod
1
0
Fork 0
mirror of https://github.com/VCMP-SqMod/SqMod.git synced 2024-11-08 00:37:15 +01:00
Code Releases Activity

Update ThreadPool.hpp

Browse Source
This commit is contained in:
Sandu Liviu Catalin 2022-06-23 21:50:23 +03:00
parent 2d24860905
commit c4130c589f
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
module/Core/ThreadPool.hpp
View File

@ -171,7 +171,7 @@ public:
void Process(); void Process();
/* -------------------------------------------------------------------------------------------- /* --------------------------------------------------------------------------------------------
* Queue an item to be processed. * Queue an item to be processed. Will take ownership of the given pointer!
*/ */
void Enqueue(ThreadPoolItem * item) void Enqueue(ThreadPoolItem * item)
{ {
@ -191,16 +191,18 @@ public:
} }
else else
{ {
// Take ownership
Item i{item};
// Perform the task in-place // Perform the task in-place
if (item->OnPrepare()) if (i->OnPrepare())
{ {
if (item->OnProcess()) if (i->OnProcess())
{ {
item->OnAborted(true); // Not accepted in single thread i->OnAborted(true); // Not accepted in single thread
} }
} }
// Item was finished in main thread // Task is completed in processing stage
item->OnCompleted(); m_Finished.enqueue(std::move(i));
} }
} }