Skip to content

Commit 01799e6

Browse files
committed
Use crossbeam channel
1 parent bcca0a3 commit 01799e6

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

Cargo.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,7 @@ salsa-macros = { version = "0.22.0", path = "components/salsa-macros", optional
1515
boxcar = { version = "0.2.12" }
1616
crossbeam-queue = "0.3.11"
1717
crossbeam-utils = "0.8.21"
18+
crossbeam-channel = "0.5.15"
1819
dashmap = { version = "6", features = ["raw-api"] }
1920
# the version of hashbrown used by dashmap
2021
hashbrown_14 = { version = "0.14", package = "hashbrown" }
@@ -52,7 +53,6 @@ salsa-macros = { version = "=0.22.0", path = "components/salsa-macros" }
5253

5354
[dev-dependencies]
5455
# examples
55-
crossbeam-channel = "0.5.14"
5656
eyre = "0.6.8"
5757
notify-debouncer-mini = "0.4.1"
5858
ordered-float = "4.2.1"

src/table/memo.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -102,12 +102,12 @@ pub fn run_memo_drops(receiver: &MemoDropReceiver) {
102102
}
103103

104104
pub fn memo_drop_channel() -> (MemoDropSender, MemoDropReceiver) {
105-
let (tx, rx) = std::sync::mpsc::channel();
105+
let (tx, rx) = crossbeam_channel::unbounded();
106106
(MemoDropSender(tx), MemoDropReceiver(rx))
107107
}
108108

109109
#[derive(Clone)]
110-
pub struct MemoDropSender(std::sync::mpsc::Sender<MemoDropAction>);
110+
pub struct MemoDropSender(crossbeam_channel::Sender<MemoDropAction>);
111111

112112
impl MemoDropSender {
113113
/// Put the memo into the drop queue.
@@ -133,7 +133,7 @@ impl MemoDropSender {
133133
}
134134
}
135135

136-
pub struct MemoDropReceiver(std::sync::mpsc::Receiver<MemoDropAction>);
136+
pub struct MemoDropReceiver(crossbeam_channel::Receiver<MemoDropAction>);
137137

138138
/// A drop action to be performed by the owner of the `MemoDropReceiver`.
139139
#[derive(Debug)]

0 commit comments

Comments
 (0)