feat: 逐步移除 std

Author: share121

.github/workflows/test.yml

@@ -33,11 +33,14 @@ jobs:
           echo "SCCACHE_GHA_ENABLED=true" >> $GITHUB_ENV
           echo "RUSTC_WRAPPER=sccache" >> $GITHUB_ENV
 
-      - name: Clippy
-        run: cargo clippy --all-targets --all-features --verbose -- -Dwarnings
-
       - name: Test
-        run: cargo test --all-targets --all-features --verbose
+        run: cargo test --all --verbose
+
+      - name: Build
+        run: cargo build --all --verbose
+
+      - name: Clippy
+        run: cargo clippy --all --verbose -- -Dwarnings
 
   check-minimal:
     name: Check minimal versions

Cargo.lock

@@ -14,7 +14,7 @@ keywords = ["downloader", "parallel", "thread", "concurrency", "performance"]
 categories = ["network-programming", "concurrency"]
 
 [dependencies]
-tokio = { version = "1.47.0", features = [
+tokio = { version = "1.47.1", features = [
     "fs",
     "macros",
     "sync",
@@ -25,7 +25,7 @@ tokio = { version = "1.47.0", features = [
 kanal = "0.1.1"
 bytes = "1.10.1"
 futures = "0.3.31"
-fast-steal = "5.0.2"
+fast-steal = "5.1.0"
 memmap2 = { version = "0.9.7", optional = true }
 reqwest = { version = "0.12.22", features = [
     "gzip",

Cargo.toml

@@ -1,6 +1,6 @@
 macro_rules! check_running {
     ($id:expr, $running:expr, $tx:expr) => {
-        if !$running.load(std::sync::atomic::Ordering::Relaxed) {
+        if !$running.load(core::sync::atomic::Ordering::Relaxed) {
             $tx.send($crate::Event::Abort($id)).await.unwrap();
             return;
         }

src/core/macros.rs

@@ -1,17 +1,18 @@
+extern crate alloc;
 use crate::{ProgressEntry, RandReader, RandWriter, SeqReader, SeqWriter};
+use alloc::sync::Arc;
 use bytes::Bytes;
 use futures::{TryStream, lock::Mutex, stream};
-use std::sync::Arc;
 
 pub fn build_mock_data(size: usize) -> Vec<u8> {
     (0..size).map(|i| (i % 256) as u8).collect()
 }
 
 #[derive(Clone)]
-pub struct MockRandReader(pub Arc<Vec<u8>>);
+pub struct MockRandReader(pub Arc<[u8]>);
 impl MockRandReader {
-    pub fn new(data: Vec<u8>) -> Self {
-        Self(Arc::new(data))
+    pub fn new(data: &[u8]) -> Self {
+        Self(Arc::from(data))
     }
 }
 impl RandReader for MockRandReader {
@@ -41,13 +42,13 @@ impl SeqReader for MockSeqReader {
 #[derive(Clone)]
 pub struct MockRandWriter {
     pub receive: Arc<Mutex<Vec<u8>>>,
-    pub result: Arc<Vec<u8>>,
+    pub result: Arc<[u8]>,
 }
 impl MockRandWriter {
-    pub fn new(result: Vec<u8>) -> Self {
+    pub fn new(result: &[u8]) -> Self {
         Self {
             receive: Arc::new(Mutex::new(vec![0; result.len()])),
-            result: Arc::new(result),
+            result: Arc::from(result),
         }
     }
     pub async fn assert(&self) {
@@ -67,12 +68,12 @@ impl RandWriter for MockRandWriter {
 #[derive(Clone)]
 pub struct MockSeqWriter {
     pub receive: Arc<Mutex<Vec<u8>>>,
-    pub result: Arc<Vec<u8>>,
+    pub result: Arc<[u8]>,
 }
 impl MockSeqWriter {
-    pub fn new(result: Vec<u8>) -> Self {
+    pub fn new(result: &[u8]) -> Self {
         Self {
-            result: Arc::new(result),
+            result: Arc::from(result),
             receive: Arc::new(Mutex::new(vec![])),
         }
     }

src/core/mock.rs

@@ -1,16 +1,17 @@
+extern crate alloc;
 use crate::Event;
+use alloc::sync::Arc;
 use core::{
     fmt::Debug,
     sync::atomic::{AtomicBool, Ordering},
 };
 use futures::lock::Mutex;
 use kanal::AsyncReceiver;
-use std::sync::Arc;
 use tokio::task::{JoinError, JoinHandle};
 
 mod macros;
 #[cfg(test)]
-mod mock;
+pub mod mock;
 pub mod multi;
 pub mod single;