diff options
Diffstat (limited to 'frameworks')
| -rw-r--r-- | frameworks/libThread.fwrk/src/ThreadManager.cpp | 28 |
1 files changed, 26 insertions, 2 deletions
diff --git a/frameworks/libThread.fwrk/src/ThreadManager.cpp b/frameworks/libThread.fwrk/src/ThreadManager.cpp index 9b222ab..f01bbfe 100644 --- a/frameworks/libThread.fwrk/src/ThreadManager.cpp +++ b/frameworks/libThread.fwrk/src/ThreadManager.cpp @@ -11,9 +11,29 @@ /// @brief The registered thread for a specific process. static ThreadRef kThreadMap[kThreadMapMax]; +/// @brief Exit codes as we want to track them. +static SInt32 kThreadExitCodes[kThreadMapMax]; + /// @brief This hash-list stores the thread to be run. static ThreadRef kThreadHeads[kThreadMapMax]; +static ThreadRef kCurrentThread; + +static __THREAD_UNSAFE Void _ThrRunThread(SInt32 argument_count, VoidPtr args, + ThrProcKind procedure, ThreadRef ref) { + static SemaphoreRef sem_ref = SemCreate(0, 1000, "ThreadSem"); + + if (sem_ref) return; + + auto ret = procedure(argument_count, (Char**) args); + kThreadExitCodes[kThreadMapMax % ref->__hash] = ret; + + if (ref == kCurrentThread) kCurrentThread = nullptr; + + SemClose(sem_ref); + sem_ref = nullptr; +} + IMPORT_C ThreadRef ThrCreateThread(const Char* thread_name, ThrProcKind procedure, SInt32 argument_count, VoidPtr args, SInt32 flags) { ThreadRef ref = new REF_TYPE; @@ -26,12 +46,16 @@ IMPORT_C ThreadRef ThrCreateThread(const Char* thread_name, ThrProcKind procedur } ref->__hash = *(UInt32*) thread_name; - ref->__hash += kThreadBaseHash; + ref->__hash += kThreadBaseHash; // pad hash with a seed. ref->__self = (VoidPtr) procedure; - kThreadMap[kThreadMapMax % ref->__hash] = ref; + kThreadMap[kThreadMapMax % ref->__hash] = ref; kThreadHeads[kThreadMapMax % ref->__hash] = ref; + kCurrentThread = ref; + + _ThrRunThread(argument_count, args, procedure, ref); + return ref; } |