improve testing coverage

Author: loongs-zhang

.github/workflows/coverage.yml

@@ -16,8 +16,8 @@ env:
 
 jobs:
   coverage:
-    name: Run cargo coverage
-    runs-on: ubuntu-latest
+    name: Run cargo coverage on ${{ matrix.os }}
+    runs-on: ${{ matrix.os }}
     steps:
       - name: Checkout sources
         uses: actions/checkout@v4
@@ -31,10 +31,21 @@ jobs:
       - name: Install cargo-llvm-cov
         uses: taiki-e/install-action@cargo-llvm-cov
       - name: Generate code coverage
-        run: sudo bash -c "ulimit -Sl 512 && ulimit -Hl 512 && sudo -u runner /home/runner/.cargo/bin/cargo llvm-cov --release --all --lcov --output-path lcov.info"
+        run: bash -c "${{ matrix.cargo }} llvm-cov --release --all --lcov --output-path lcov.info"
       - name: Generate code coverage with all features
-        run: sudo bash -c "ulimit -Sl 512 && ulimit -Hl 512 && sudo -u runner /home/runner/.cargo/bin/cargo llvm-cov --all-features --release --all --lcov --output-path lcov-all-features.info"
+        run: bash -c "${{ matrix.cargo }} llvm-cov --all-features --release --all --lcov --output-path lcov-all-features.info"
       - name: Upload coverage to Codecov
         run: |
           bash <(curl -s https://codecov.io/bash) -f lcov.info -t ${{ env.CODECOV_TOKEN }}
           bash <(curl -s https://codecov.io/bash) -f lcov-all-features.info -t ${{ env.CODECOV_TOKEN }}
+
+    strategy:
+      fail-fast: false
+      matrix:
+        include:
+          - os: ubuntu-latest
+            cargo: ulimit -Sl 512 && ulimit -Hl 512 && sudo -u runner /home/runner/.cargo/bin/cargo
+          - os: macos-14
+            cargo: ulimit -Sl 512 && ulimit -Hl 512 && sudo -u runner /Users/runner/.cargo/bin/cargo
+          - os: windows-latest
+            cargo: C://Users//runneradmin//.cargo//bin//cargo.exe

core/src/co_pool/mod.rs

@@ -6,7 +6,7 @@ use crate::common::ordered_work_steal::{OrderedLocalQueue, OrderedWorkStealQueue
 use crate::common::{get_timeout_time, now, CondvarBlocker};
 use crate::coroutine::suspender::Suspender;
 use crate::scheduler::{SchedulableCoroutine, Scheduler};
-use crate::{impl_current_for, impl_display_by_debug, impl_for_named, trace};
+use crate::{error, impl_current_for, impl_display_by_debug, impl_for_named, trace};
 use dashmap::DashMap;
 use std::cell::Cell;
 use std::ffi::c_longlong;
@@ -70,10 +70,9 @@ impl Drop for CoroutinePool<'_> {
             self.get_running_size(),
             "There are still tasks in progress !"
         );
-        assert!(
-            self.task_queue.is_empty(),
-            "There are still tasks to be carried out !"
-        );
+        if self.task_queue.is_empty() {
+            error!("Forget some tasks when closing the pool");
+        }
     }
 }