- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for maybeRunChan (0.11 sec)
-
src/runtime/chan.go
// use non-blocking sends to fill the buffer). func timerchandrain(c *hchan) bool { // Note: Cannot use empty(c) because we are called // while holding c.timer.sendLock, and empty(c) will // call c.timer.maybeRunChan, which will deadlock. // We are emptying the channel, so we only care about // the count, not about potentially filling it up. if atomic.Loaduint(&c.qcount) == 0 { return false } lock(&c.lock)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:50 UTC 2024 - 25.9K bytes - Viewed (0)