We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
mpsc
1 parent 357f1e3 commit 5d155e8Copy full SHA for 5d155e8
std/src/sync/mpmc/context.rs
@@ -115,21 +115,6 @@ impl Context {
115
/// If the deadline is reached, `Selected::Aborted` will be selected.
116
#[inline]
117
pub fn wait_until(&self, deadline: Option<Instant>) -> Selected {
118
- // Spin for a short time, waiting until an operation is selected.
119
- let backoff = Backoff::new();
120
- loop {
121
- let sel = Selected::from(self.inner.select.load(Ordering::Acquire));
122
- if sel != Selected::Waiting {
123
- return sel;
124
- }
125
-
126
- if backoff.is_completed() {
127
- break;
128
- } else {
129
- backoff.snooze();
130
131
132
133
loop {
134
// Check whether an operation has been selected.
135
let sel = Selected::from(self.inner.select.load(Ordering::Acquire));
0 commit comments