fixup! Add callbacks for when threads start and stop doing work

cuviper · cuviper · commit 5a1f189fbd6e · 2022-05-27T20:16:14.000-07:00
diff --git a/rayon-core/src/sleep/mod.rs b/rayon-core/src/sleep/mod.rs
@@ -281,10 +281,12 @@ impl Sleep {
             // that whomever is coming to wake us will have to wait until we
             // release the mutex in the call to `wait`, so they will see this
             // boolean as true.)
+            registry.release_thread();
             *is_blocked = true;
             while *is_blocked {
                 is_blocked = sleep_state.condvar.wait(is_blocked).unwrap();
             }
+            registry.acquire_thread();
         }
 
         // Update other state:

Original file line number	Diff line number	Diff line change
`@@ -281,10 +281,12 @@ impl Sleep {`
`281`	`281`	`// that whomever is coming to wake us will have to wait until we`
`282`	`282`	// release the mutex in the call to `wait`, so they will see this
`283`	`283`	`// boolean as true.)`
	`284`	`+ registry.release_thread();`
`284`	`285`	`*is_blocked = true;`
`285`	`286`	`while *is_blocked {`
`286`	`287`	`is_blocked = sleep_state.condvar.wait(is_blocked).unwrap();`
`287`	`288`	`}`
	`289`	`+ registry.acquire_thread();`
`288`	`290`	`}`
`289`	`291`
`290`	`292`	`// Update other state:`