We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ba9d102 commit a4cce12Copy full SHA for a4cce12
1 file changed
futures-core/src/task/__internal/atomic_waker.rs
@@ -385,7 +385,8 @@ impl AtomicWaker {
385
let waker = unsafe { (*self.waker.get()).take() };
386
387
// Release the lock
388
- self.state.fetch_and(!WAKING, Release);
+ let old_state = self.state.swap(WAITING, Release);
389
+ debug_assert!(old_state == WAKING);
390
391
waker
392
}
0 commit comments