Introduce primitive threading in unified scheduler (#34676)

* Introduce primitive threading in unified scheduler

* Make the internal struct ExecutedTask not pub

* Improve wording a bit

* Explain scheduler main loop's overhead sensitivity

* Improve wording a bit

* Define ChainedChannel{Sender, Receiver} wrappers

* Clean up a bit

* Use derivative to avoid manual Clone impl

* Clarify comment

* Remove extra whitespace in comment

* Remove unneeded dyn trait for ChainedChannel

* Remove the accumulator thread for now

* Fix typo

* Use unimplemented!() to convey intention better

Cargo.toml

@@ -185,6 +185,7 @@ ctrlc = "3.4.2"
 curve25519-dalek = "3.2.1"
 dashmap = "5.5.3"
 derivation-path = { version = "0.2.0", default-features = false }
+derivative = "2.2.0"
 dialoguer = "0.10.4"
 digest = "0.10.7"
 dir-diff = "0.3.3"

unified-scheduler-logic/Cargo.toml

@@ -8,3 +8,6 @@ repository = { workspace = true }
 homepage = { workspace = true }
 license = { workspace = true }
 edition = { workspace = true }
+
+[dependencies]
+solana-sdk = { workspace = true }

unified-scheduler-logic/src/lib.rs

@@ -1 +1,20 @@
-// This file will be populated with actual implementation later.
+use solana_sdk::transaction::SanitizedTransaction;
+
+pub struct Task {
+    transaction: SanitizedTransaction,
+    index: usize,
+}
+
+impl Task {
+    pub fn create_task(transaction: SanitizedTransaction, index: usize) -> Self {
+        Task { transaction, index }
+    }
+
+    pub fn task_index(&self) -> usize {
+        self.index
+    }
+
+    pub fn transaction(&self) -> &SanitizedTransaction {
+        &self.transaction
+    }
+}

unified-scheduler-pool/Cargo.toml

@@ -10,6 +10,10 @@ license = { workspace = true }
 edition = { workspace = true }
 
 [dependencies]
+assert_matches = { workspace = true }
+crossbeam-channel = { workspace = true }
+derivative = { workspace = true }
+log = { workspace = true }
 solana-ledger = { workspace = true }
 solana-program-runtime = { workspace = true }
 solana-runtime = { workspace = true }