diff --git a/Cargo.toml b/Cargo.toml index 58ce5e8d..6ee406e7 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -31,7 +31,7 @@ polling = "2.8.0" educe = "0.6.0" libc = "0.2" -rand = "0.8" +rand = "0.9" st3 = "0.4" crossbeam-deque = "0.8" time = "0.3" diff --git a/core/src/common/ordered_work_steal.rs b/core/src/common/ordered_work_steal.rs index b61b34ec..29c795ac 100644 --- a/core/src/common/ordered_work_steal.rs +++ b/core/src/common/ordered_work_steal.rs @@ -359,7 +359,7 @@ impl<'l, T: Debug> OrderedLocalQueue<'l, T> { //尝试从其他本地队列steal let local_queues = &self.shared.local_queues; let num = local_queues.len(); - let start = rand::thread_rng().gen_range(0..num); + let start = rand::rng().random_range(0..num); for i in 0..num { let i = (start + i) % num; if let Some(another) = local_queues.get(i) { diff --git a/core/src/common/work_steal.rs b/core/src/common/work_steal.rs index 170d7775..3346e45a 100644 --- a/core/src/common/work_steal.rs +++ b/core/src/common/work_steal.rs @@ -291,7 +291,7 @@ impl<'l, T: Debug> LocalQueue<'l, T> { //尝试从其他本地队列steal let local_queues = &self.shared.local_queues; let num = local_queues.len(); - let start = rand::thread_rng().gen_range(0..num); + let start = rand::rng().random_range(0..num); for i in 0..num { let i = (start + i) % num; if let Some(another) = local_queues.get(i) { diff --git a/core/src/net/event_loop.rs b/core/src/net/event_loop.rs index 41d3f25c..21d9324a 100644 --- a/core/src/net/event_loop.rs +++ b/core/src/net/event_loop.rs @@ -75,7 +75,7 @@ impl DerefMut for EventLoop<'_> { impl Default for EventLoop<'_> { fn default() -> Self { let max_cpu_index = num_cpus::get(); - let random_cpu_index = rand::thread_rng().gen_range(0..max_cpu_index); + let random_cpu_index = rand::rng().random_range(0..max_cpu_index); Self::new( format!("open-coroutine-event-loop-{random_cpu_index}"), random_cpu_index, diff --git a/core/src/syscall/unix/connect.rs b/core/src/syscall/unix/connect.rs index 14479e7f..108fdb1a 100644 --- a/core/src/syscall/unix/connect.rs +++ b/core/src/syscall/unix/connect.rs @@ -84,7 +84,7 @@ impl ConnectSyscall for NioConnectSyscall { set_errno(err); r = -1; break; - }; + } unsafe { let mut address = std::mem::zeroed(); let mut address_len = socklen_t::try_from(size_of_val(&address)).expect("overflow"); diff --git a/core/src/syscall/windows/connect.rs b/core/src/syscall/windows/connect.rs index 4711c61b..dbe23df3 100644 --- a/core/src/syscall/windows/connect.rs +++ b/core/src/syscall/windows/connect.rs @@ -82,7 +82,7 @@ impl ConnectSyscall for NioConnectSyscall { set_errno(err); r = -1; break; - }; + } unsafe { let mut address = std::mem::zeroed(); let mut address_len = c_int::try_from(size_of_val(&address)).expect("overflow");