diff --git a/Cargo.toml b/Cargo.toml index 647951b2..d07c55f8 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -23,7 +23,7 @@ derive_more = { version = "2.0.1", features = ["from", "error", "display", "into tokio = { version = "1", features = ["full"] } tracing = "0.1" rkyv = { version = "0.8.9", features = ["uuid-1"] } -lockfree = { version = "0.5.1" } +lock_freedom = "0.1" fastrand = "2.3.0" futures = "0.3.30" uuid = { version = "1.10.0", features = ["v4", "v7"] } diff --git a/performance_measurement/Cargo.toml b/performance_measurement/Cargo.toml index 2d9a7c52..fe4f722b 100644 --- a/performance_measurement/Cargo.toml +++ b/performance_measurement/Cargo.toml @@ -8,4 +8,4 @@ description = "Package taht can be used to measuere function execution time" [dependencies] lazy_static = {version = "1.5.0"} derive_more = {version = "1.0.0", features = ["display"]} -lockfree = {version = "0.5.1"} +lock_freedom = "0.1" diff --git a/performance_measurement/src/profiler.rs b/performance_measurement/src/profiler.rs index 6c78532b..040df7cf 100644 --- a/performance_measurement/src/profiler.rs +++ b/performance_measurement/src/profiler.rs @@ -3,7 +3,7 @@ use std::time::{Duration, Instant}; use derive_more::Display; use lazy_static::lazy_static; -use lockfree::map::Map; +use lock_freedom::map::Map; lazy_static! { static ref GLOBAL_PERFORMANCE_MEASUREMENTS: Map<&'static str, PerformanceMeasurement> = diff --git a/src/in_memory/pages.rs b/src/in_memory/pages.rs index 65823b94..1254183a 100644 --- a/src/in_memory/pages.rs +++ b/src/in_memory/pages.rs @@ -6,7 +6,7 @@ use std::{ use data_bucket::page::PageId; use derive_more::{Display, Error, From}; -use lockfree::stack::Stack; +use lock_freedom::stack::Stack; #[cfg(feature = "perf_measurements")] use performance_measurement_codegen::performance_measurement; use rkyv::{ diff --git a/src/persistence/task.rs b/src/persistence/task.rs index ea90f2a2..33183709 100644 --- a/src/persistence/task.rs +++ b/src/persistence/task.rs @@ -296,7 +296,7 @@ where #[derive(Debug)] pub struct Queue { - queue: lockfree::queue::Queue>, + queue: lock_freedom::queue::Queue>, notify: Notify, len: Arc, } @@ -306,7 +306,7 @@ impl { pub fn new() -> Self { Self { - queue: lockfree::queue::Queue::new(), + queue: lock_freedom::queue::Queue::new(), notify: Notify::new(), len: Arc::new(AtomicU16::new(0)), }