Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for maybeRunChan (0.11 sec)

  1. 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)
Back to top