Skip to content

Commit d8897d2

Browse files
committed
Reduce useless lock() of LinkedListAsync<T>
1 parent b67cc32 commit d8897d2

File tree

1 file changed

+10
-10
lines changed

1 file changed

+10
-10
lines changed

src/common.rs

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -215,15 +215,15 @@ where
215215
type Item = T;
216216

217217
fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
218-
let mut inner = self.inner.lock().unwrap();
218+
// let mut inner = self.inner.lock().unwrap();
219219
let alive = self.alive.lock().unwrap();
220220
let mut waker = self.waker.lock().unwrap();
221221

222222
let picked: Option<T>;
223223
// {
224224
// picked = self.pop_front();
225225
// }
226-
picked = inner.pop_front();
226+
picked = self.pop_front();
227227
if picked.is_some() {
228228
return Poll::Ready(picked);
229229
}
@@ -235,14 +235,14 @@ where
235235
// picked = inner.pop_front();
236236

237237
// Check Pending(None) or Ready(Some(item))
238-
if picked.is_none() {
239-
// Keep Pending
240-
{
241-
waker.replace(cx.waker().clone());
242-
};
243-
return Poll::Pending;
244-
}
245-
return Poll::Ready(picked);
238+
// if picked.is_none() {
239+
// Keep Pending
240+
{
241+
waker.replace(cx.waker().clone());
242+
};
243+
return Poll::Pending;
244+
// }
245+
// return Poll::Ready(picked);
246246
}
247247
return Poll::Ready(None);
248248
}

0 commit comments

Comments
 (0)