Author: NikolaRHristov

Source/Library.rs

@@ -12,4 +12,4 @@ pub mod Scheduler;
 pub mod Task;
 
 // --- Internal Implementation ---
-mod Queue;
+pub mod Queue;

Source/Queue/mod.rs

@@ -6,7 +6,7 @@
 
 #![allow(non_snake_case, non_camel_case_types)]
 
-mod StealingQueue;
+pub mod StealingQueue;
 
 // Re-exports the `StealingQueue` for use within the `Echo` crate, but keeps it
 // private from external consumers.

Source/Scheduler/SchedulerBuilder.rs

@@ -33,7 +33,7 @@ impl SchedulerBuilder {
 	/// By default, the worker count is set to the number of logical CPUs on the
 	/// system, with a minimum of 2.
 	pub fn New() -> Self {
-		let DefaultWorkerCount = num_cpus::get().max(2);
+		let DefaultWorkerCount = num_cpus::get().max(2).expect("");
 		Self { WorkerCount:DefaultWorkerCount, QueueConfiguration:HashMap::new() }
 	}
 
@@ -45,7 +45,7 @@ impl SchedulerBuilder {
 	pub fn WithWorkerCount(mut self, WorkerCount:usize) -> Self {
 		if WorkerCount == 0 {
 			warn!("[SchedulerBuilder] Worker count of 0 is invalid. Defaulting to number of logical CPUs.");
-			self.WorkerCount = num_cpus::get().max(2);
+			self.WorkerCount = num_cpus::get().max(2).expect("");
 		} else {
 			self.WorkerCount = WorkerCount;
 		}

Source/Scheduler/Worker.rs

@@ -10,7 +10,7 @@ use tokio::time::{Duration, sleep};
 /// @description Defines the `Worker` struct, which represents a single
 /// execution thread in the scheduler's pool. This is an internal component of
 /// the scheduler.
-use crate::queue::StealingQueue;
+use crate::Queue::StealingQueue;
 
 /// Represents a single worker thread that continuously polls the work-stealing
 /// queue for tasks to execute.

Source/Task/mod.rs

@@ -6,15 +6,15 @@
 #![allow(non_snake_case, non_camel_case_types)]
 
 // --- Sub-modules ---
-mod Priority;
-mod Task;
+pub mod Priority;
+pub mod Task;
 
 // --- Public Re-exports ---
 
 // The enum representing the priority of a task.
 // @see Priority
 //
-pub use self::Priority::Priority;
+// pub use self::Priority::Priority;
 // The struct representing a single unit of work for the scheduler.
 // @see Task
-pub use self::Task::Task;
+// pub use self::Task::Task;