- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for sched (0.15 sec)
-
src/runtime/debug.go
// This call will go away when the scheduler improves. func GOMAXPROCS(n int) int { if GOARCH == "wasm" && n > 1 { n = 1 // WebAssembly has no threads yet, so only one CPU is possible. } lock(&sched.lock) ret := int(gomaxprocs) unlock(&sched.lock) if n <= 0 || n == ret { return ret } stw := stopTheWorldGC(stwGOMAXPROCS) // newprocs will be processed by startTheWorld newprocs = int32(n) startTheWorldGC(stw)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat May 11 20:38:24 UTC 2024 - 4.2K bytes - Viewed (0) -
src/runtime/mklockrank.go
forcegc, hchan, pollDesc, # pollDesc can interact with timers, which can lock sched. scavenge, sweep, sweepWaiters, testR, wakeableSleep # Above SCHED are things that can call into the scheduler. < SCHED # Below SCHED is the scheduler implementation. < allocmR, execR; allocmR, execR, hchan < sched; sched < allg, allp; # Channels NONE < notifyList; hchan, notifyList < sudog;
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:47:01 UTC 2024 - 9.1K bytes - Viewed (0) -
src/cmd/link/internal/ld/inittask.go
} } // Sort edges so we can look them up by edge destination. sort.Slice(edges, func(i, j int) bool { return edges[i].to < edges[j].to }) // Figure out the schedule. sched := ldr.MakeSymbolBuilder(symName) sched.SetType(sym.SNOPTRDATA) // Could be SRODATA, but see issue 58857. for !h.empty() { // Pick the lexicographically first initializable package. s := h.pop(ldr) // Add s to the schedule.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jan 30 20:09:45 UTC 2024 - 6.2K bytes - Viewed (0) -
src/runtime/badlinkname.go
// - github.com/outcaste-io/ristretto // - github.com/clubpay/ronykit //go:linkname cputicks // Notable members of the hall of shame include: // - gvisor.dev/gvisor (from assembly)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 661 bytes - Viewed (0) -
src/runtime/align_runtime_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 1.8K bytes - Viewed (0) -
src/runtime/debugcall.go
// transition anymore. trace.GoSched() } casgstatus(gp, _Grunning, _Grunnable) if trace.ok() { traceRelease(trace) } dropg() lock(&sched.lock) globrunqput(gp) unlock(&sched.lock) trace = traceAcquire() casgstatus(callingG, _Gwaiting, _Grunnable) if trace.ok() { trace.GoUnpark(callingG, 0) traceRelease(trace) } execute(callingG, true)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 05 20:50:21 UTC 2024 - 7.1K bytes - Viewed (0) -
src/runtime/tracestatus.go
func (r *traceSchedResourceState) readyNextGen(gen uintptr) { nextGen := traceNextGen(gen) r.seq[nextGen%2] = 0 r.statusTraced[nextGen%3].Store(0) } // statusWasTraced returns true if the sched resource's status was already acquired for tracing. func (r *traceSchedResourceState) statusWasTraced(gen uintptr) bool { return r.statusTraced[gen%3].Load() != 0 }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 17:03:35 UTC 2024 - 7.2K bytes - Viewed (0) -
src/runtime/coro.go
gnext.lockedm.set(mp) } // Release the trace locker. We've completed all the necessary transitions.. if trace.ok() { traceRelease(trace) } // Switch to gnext. Does not return. gogo(&gnext.sched)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 19:09:18 UTC 2024 - 7.4K bytes - Viewed (0)