- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for runqdrain (0.17 sec)
-
src/runtime/proc.go
if atomic.CasRel(&pp.runqhead, h, h+1) { // cas-release, commits consume return gp, false } } } // runqdrain drains the local runnable queue of pp and returns all goroutines in it. // Executed only by the owner P. func runqdrain(pp *p) (drainQ gQueue, n uint32) { oldNext := pp.runnext if oldNext != 0 && pp.runnext.cas(oldNext, 0) { drainQ.pushBack(oldNext.ptr()) n++ }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 207.5K bytes - Viewed (0)