1 files changed, 61 insertions, 0 deletions
diff --git a/frameworks/libThread.fwrk/src/ThreadMgr.cpp b/frameworks/libThread.fwrk/src/ThreadMgr.cpp
new file mode 100644
index 0000000..f01bbfe
--- /dev/null
+++ b/frameworks/libThread.fwrk/src/ThreadMgr.cpp
@@ -0,0 +1,61 @@
+// SPDX-License-Identifier: Apache-2.0
+// Copyright 2026, Amlal El Mahrouss (amlal@nekernel.org)
+// Licensed under the Apache License, Version 2.0 (see LICENSE file)
+// Official repository: https://github.com/ne-foss-org/ne_system
+
+#include <libSystem/SystemKit/System.h>
+
+#define kThreadMapMax (1024UL)
+#define kThreadBaseHash (0x5555ffff6ULL)
+
+/// @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;
+  if (!ref) return nullptr;
+
+  if (!thread_name || !procedure) {
+    delete ref;
+    ref = nullptr;
+    return nullptr;
+  }
+
+  ref->__hash = *(UInt32*) thread_name;
+  ref->__hash += kThreadBaseHash; // pad hash with a seed.
+
+  ref->__self = (VoidPtr) procedure;
+
+  kThreadMap[kThreadMapMax % ref->__hash]   = ref;
+  kThreadHeads[kThreadMapMax % ref->__hash] = ref;
+
+  kCurrentThread = ref;
+
+  _ThrRunThread(argument_count, args, procedure, ref);
+
+  return ref;
+}