Relax ordering in local_pool.rs

taiki-e · taiki-e · commit 4b1591059042 · 2022-08-14T21:18:33.000+09:00
diff --git a/futures-executor/src/local_pool.rs b/futures-executor/src/local_pool.rs
@@ -104,7 +104,7 @@ fn run_executor<T, F: FnMut(&mut Context<'_>) -> Poll<T>>(mut f: F) -> T {
 
 /// Check for a wakeup, but don't consume it.
 fn woken() -> bool {
-    CURRENT_THREAD_NOTIFY.with(|thread_notify| thread_notify.unparked.load(Ordering::SeqCst))
+    CURRENT_THREAD_NOTIFY.with(|thread_notify| thread_notify.unparked.load(Ordering::Acquire))
 }
 
 impl LocalPool {

Original file line number	Diff line number	Diff line change
`@@ -104,7 +104,7 @@ fn run_executor<T, F: FnMut(&mut Context<'_>) -> Poll<T>>(mut f: F) -> T {`
`104`	`104`
`105`	`105`	`/// Check for a wakeup, but don't consume it.`
`106`	`106`	`fn woken() -> bool {`
`107`		`- CURRENT_THREAD_NOTIFY.with(\|thread_notify\| thread_notify.unparked.load(Ordering::SeqCst))`
	`107`	`+ CURRENT_THREAD_NOTIFY.with(\|thread_notify\| thread_notify.unparked.load(Ordering::Acquire))`
`108`	`108`	`}`
`109`	`109`
`110`	`110`	`impl LocalPool {`