Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for globrunqputbatch (0.12 sec)

  1. src/runtime/proc.go

    	if pp == nil {
    		lock(&sched.lock)
    		globrunqputbatch(&q, int32(qsize))
    		unlock(&sched.lock)
    		startIdle(qsize)
    		return
    	}
    
    	npidle := int(sched.npidle.Load())
    	var (
    		globq gQueue
    		n     int
    	)
    	for n = 0; n < npidle && !q.empty(); n++ {
    		g := q.pop()
    		globq.pushBack(g)
    	}
    	if n > 0 {
    		lock(&sched.lock)
    		globrunqputbatch(&globq, int32(n))
    		unlock(&sched.lock)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 207.5K bytes
    - Viewed (0)
  2. src/runtime/mgc.go

    					// a useful signal to kick
    					// everything out of the run
    					// queue so it can run
    					// somewhere else.
    					if drainQ, n := runqdrain(pp); n > 0 {
    						lock(&sched.lock)
    						globrunqputbatch(&drainQ, int32(n))
    						unlock(&sched.lock)
    					}
    				}
    				// Go back to draining, this time
    				// without preemption.
    				gcDrainMarkWorkerDedicated(&pp.gcw, false)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 62K bytes
    - Viewed (0)
Back to top