AuroraSupport/AuroraRuntime
2
1
Fork 0
Code Issues 27 Pull Requests Releases Wiki Activity

[*] Improved AuThreads::Spawn prototypes with new optional finalizer arg

Browse Source
This commit is contained in:
Reece Wilson 2024-03-10 10:16:28 +00:00
parent 58e8209cff
commit 41412876b6
1 changed files with 36 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
Include/Aurora/Threading/Threads/Spawn.hpp
View File

@ -11,24 +11,48 @@ namespace Aurora::Threading::Threads
{ {
static ThreadUnique_t Spawn(AuVoidFunc entrypoint, static ThreadUnique_t Spawn(AuVoidFunc entrypoint,
bool bDetached = false, bool bDetached = false,
AuUInt32 uStackSize = 0) AuOptional<AuUInt32> optuStackSize = { 0 },
AuOptional<AuString> optName = { })
{ {
auto thread = ThreadUnique(ThreadInfo( ThreadInfo threadInfo(
AuMakeShared<IThreadVectorsFunctional>(IThreadVectorsFunctional::OnEntry_t(std::bind(entrypoint)), IThreadVectorsFunctional::OnExit_t {}), AuMakeShared<IThreadVectorsFunctional>(IThreadVectorsFunctional::OnEntry_t(std::bind(entrypoint)), IThreadVectorsFunctional::OnExit_t {}),
uStackSize optuStackSize.ValueOr(0)
)); );
if (!thread) SysCheckNotNullMemory(AuTryConstruct(threadInfo.name, optName.ValueOr(AuString {})), {});
SysCheckNotNullMemory(threadInfo.callbacks, ThreadUnique_t {});
auto thread = ThreadUnique(threadInfo);
SysCheckNotNullNested(thread, ThreadUnique_t {});
SysCheckNotNullNested(thread->Run(), ThreadUnique_t {});
if (bDetached)
{ {
SysPushErrorNested(); thread->Detach();
return ThreadUnique_t {};
} }
if (!thread->Run()) return AuMove(thread);
{ }
SysPushErrorNested();
return ThreadUnique_t {}; static ThreadUnique_t Spawn(AuVoidFunc entrypoint,
} AuVoidFunc finalizer,
bool bDetached = false,
AuOptional<AuUInt32> optuStackSize = { 0 },
AuOptional<AuString> optName = { })
{
ThreadInfo threadInfo(
AuMakeShared<IThreadVectorsFunctional>(IThreadVectorsFunctional::OnEntry_t(std::bind(entrypoint)), IThreadVectorsFunctional::OnExit_t(std::bind(finalizer))),
optuStackSize.ValueOr(0)
);
SysCheckNotNullMemory(AuTryConstruct(threadInfo.name, optName.ValueOr(AuString {})), { });
SysCheckNotNullMemory(threadInfo.callbacks, ThreadUnique_t {});
auto thread = ThreadUnique(threadInfo);
SysCheckNotNullNested(thread, ThreadUnique_t {});
SysCheckNotNullNested(thread->Run(), ThreadUnique_t {});
if (bDetached) if (bDetached)
{ {