diff options
| author | Amlal El Mahrouss <amlal@nekernel.org> | 2026-03-28 04:14:54 +0100 |
|---|---|---|
| committer | Amlal El Mahrouss <amlal@nekernel.org> | 2026-03-28 04:14:54 +0100 |
| commit | e2e01ed3c503cb8d93446abea162ccf9abd56201 (patch) | |
| tree | 536df79e6d6200dd261abd78945aa03ee7439e55 /src/libThread | |
| parent | 9937bcb03d4b3c3e71c33786349d4a41203550c0 (diff) | |
Signed-off-by: Amlal El Mahrouss <amlal@nekernel.org>
Diffstat (limited to 'src/libThread')
| -rw-r--r-- | src/libThread/ThreadKit/Thread.h | 11 | ||||
| -rw-r--r-- | src/libThread/doc/.keep | 0 | ||||
| -rw-r--r-- | src/libThread/libThread.json | 21 | ||||
| -rw-r--r-- | src/libThread/obj/.keep | 0 | ||||
| -rw-r--r-- | src/libThread/src/Thread.cpp | 81 |
5 files changed, 113 insertions, 0 deletions
diff --git a/src/libThread/ThreadKit/Thread.h b/src/libThread/ThreadKit/Thread.h new file mode 100644 index 00000000..e8fa7eb0 --- /dev/null +++ b/src/libThread/ThreadKit/Thread.h @@ -0,0 +1,11 @@ +// 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-kernel + +#ifndef THREADKIT_THREADKIT_H +#define THREADKIT_THREADKIT_H + +#include <libSystem/SystemKit/System.h> + +#endif // THREADKIT_THREADKIT_H diff --git a/src/libThread/doc/.keep b/src/libThread/doc/.keep new file mode 100644 index 00000000..e69de29b --- /dev/null +++ b/src/libThread/doc/.keep diff --git a/src/libThread/libThread.json b/src/libThread/libThread.json new file mode 100644 index 00000000..dc1da098 --- /dev/null +++ b/src/libThread/libThread.json @@ -0,0 +1,21 @@ +{ + "compiler_path": "x86_64-w64-mingw32-g++", + "compiler_std": "c++20", + "headers_path": ["../", "./"], + "sources_path": ["src/*.cpp"], + "output_name": "libThread.dll", + "compiler_flags": [ + "-ffreestanding", + "-shared", + "-fPIC", + "-fno-rtti", + "-fno-exceptions", + "-Wl,--subsystem=17" + ], + "cpp_macros": [ + "kLibThreadVersion=0x0100", + "kLibThreadVersionHighest=0x0100", + "kLibThreadVersionLowest=0x0100" + ], + "description": "The System Thread Kit for the NeSystem." +} diff --git a/src/libThread/obj/.keep b/src/libThread/obj/.keep new file mode 100644 index 00000000..e69de29b --- /dev/null +++ b/src/libThread/obj/.keep diff --git a/src/libThread/src/Thread.cpp b/src/libThread/src/Thread.cpp new file mode 100644 index 00000000..89a90e00 --- /dev/null +++ b/src/libThread/src/Thread.cpp @@ -0,0 +1,81 @@ +// 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-kernel + +#include <libSystem/SystemKit/Err.h> +#include <libThread/ThreadKit/Thread.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]; + +/// @brief This hash-list stores the thread to be run. +static SInt32 kThreadFlags[kThreadMapMax]; + +/// @brief Current thread reference +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; + kThreadFlags[kThreadMapMax % ref->__hash] = flags; + + kCurrentThread = ref; + + _ThrRunThread(argument_count, args, procedure, ref); + + return ref; +} + +IMPORT_C SInt32 ThrExitThread(_Input ThreadRef ref, _Input SInt32 exit_code) { + if (!ref) return kErrorInvalidData; + + kThreadMap[kThreadMapMax % ref->__hash] = nullptr; + kThreadHeads[kThreadMapMax % ref->__hash] = nullptr; + + kThreadFlags[kThreadMapMax % ref->__hash] = 0; + + if (kCurrentThread == ref) kCurrentThread = nullptr; + + kThreadExitCodes[kThreadMapMax % ref->__hash] = exit_code; + return kErrorSuccess; +}
\ No newline at end of file |
