fix compile on rust 1.83.0

Author: loongs-zhang

.github/workflows/ci.yml

@@ -86,7 +86,7 @@ jobs:
           x86_64-pc-windows-msvc,
           i686-pc-windows-msvc,
         ]
-        channel: [ 1.81.0, nightly-2024-08-02 ]
+        channel: [ stable, nightly ]
         include:
           - target: x86_64-unknown-linux-gnu
             os: ubuntu-latest

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");
+        }
     }
 }
 

core/src/syscall/windows/select.rs

@@ -97,7 +97,7 @@ impl<I: SelectSyscall> SelectSyscall for NioSelectSyscall<I> {
             }
             _ = EventLoops::wait_event(Some(Duration::from_millis(u64::from(t.min(x)))));
             if t != c_uint::MAX {
-                t = if t > x { t - x } else { 0 };
+                t = t.saturating_sub(x);
             }
             if x < 16 {
                 x <<= 1;

open-coroutine/build.rs

@@ -214,5 +214,6 @@ fn main() {
         }
     }
     // link dylib
+    println!("cargo:rustc-link-search=native={}", deps.display());
     println!("cargo:rustc-link-lib=dylib=open_coroutine_hook");
 }