From 4bde2f5421949a8cbf513c8401aa6255b78e3b00 Mon Sep 17 00:00:00 2001 From: glorv Date: Wed, 14 Dec 2022 10:40:17 +0800 Subject: [PATCH] use crates.io Signed-off-by: glorv --- Cargo.toml | 2 +- src/queue/priority.rs | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/Cargo.toml b/Cargo.toml index 59ed487..04ebcdf 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -10,7 +10,7 @@ repository = "https://github.com/tikv/yatp/" [dependencies] crossbeam-deque = "0.8" -crossbeam-skiplist = { git = "https://github.com/crossbeam-rs/crossbeam" } +crossbeam-skiplist = "0.1" dashmap = "5.1" fail = "0.5" lazy_static = "1" diff --git a/src/queue/priority.rs b/src/queue/priority.rs index 11617b4..a3b02c9 100644 --- a/src/queue/priority.rs +++ b/src/queue/priority.rs @@ -156,7 +156,8 @@ impl QueueCore { } } -/// A holder to store task. The slot can be concurrently visit by multiple thread in the skip-list. +/// A holder to store task. We wrap the value in an atomic ptr because the return value of pop() +/// only provide readonly reference to this value, though in our can it's safe to just take it. struct Slot { ptr: AtomicPtr, }