Struct ThreadManager 

pub struct ThreadManager { /* private fields */ }

Thread management system

Implementations

impl ThreadManager

pub fn new() -> Self

Create a new thread manager

pub fn create_thread( &self, params: ThreadCreateParams, process_id: ProcessId, ) -> Result<Arc<ThreadHandle>, KernelError>

Create a new thread

pub fn get_thread(&self, thread_id: ThreadId) -> Option<Arc<ThreadHandle>>

Get thread handle by ID

pub fn join_thread(&self, thread_id: ThreadId) -> Result<*mut u8, KernelError>

Join a thread (wait for it to complete)

pub fn detach_thread(&self, thread_id: ThreadId) -> Result<(), KernelError>

Detach a thread

pub fn cancel_thread(&self, thread_id: ThreadId) -> Result<(), KernelError>

Cancel a thread

Sets the cancellation flag on the thread. The thread should check is_cancel_requested() periodically and exit gracefully when cancelled. If the thread is blocked, it will be moved to Ready state to allow it to process the cancellation.

pub fn exit_thread(&self, thread_id: ThreadId, exit_value: *mut u8)

Exit current thread

pub fn set_thread_priority( &self, thread_id: ThreadId, _priority: ThreadPriority, ) -> Result<(), KernelError>

Set thread priority

pub fn get_thread_priority( &self, thread_id: ThreadId, ) -> Result<ThreadPriority, KernelError>

Get thread priority

pub fn set_cpu_affinity( &self, thread_id: ThreadId, cpu_mask: u64, ) -> Result<(), KernelError>

Set CPU affinity for thread

pub fn create_tls_key( &self, destructor: Option<fn(*mut u8)>, ) -> Result<TlsKey, KernelError>

Create thread-local storage key

pub fn delete_tls_key(&self, key: TlsKey) -> Result<(), KernelError>

Delete thread-local storage key

pub fn set_tls_value( &self, thread_id: ThreadId, key: TlsKey, value: *mut u8, ) -> Result<(), KernelError>

Set thread-local storage value

pub fn get_tls_value( &self, thread_id: ThreadId, key: TlsKey, ) -> Result<*mut u8, KernelError>

Get thread-local storage value

pub fn get_current_thread_id(&self) -> Option<ThreadId>

Get current thread ID from scheduler

pub fn list_threads(&self) -> Vec<ThreadId>

List all threads

pub fn get_thread_stats( &self, thread_id: ThreadId, ) -> Result<ThreadStats, KernelError>

Get thread statistics

Trait Implementations

impl Default for ThreadManager

fn default() -> Self

Returns the “default value” for a type.

impl Send for ThreadManager

impl Sync for ThreadManager