- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 79 for Procs (0.08 sec)
-
src/runtime/proc_runtime_test.go
// same pos+inc twice. for procs := 2; procs <= 64; procs++ { ord.reset(uint32(procs)) checked := make([]bool, procs*procs) // We want at least procs*len(ord.coprimes) different pos+inc values // before we start repeating. for i := 0; i < procs*len(ord.coprimes); i++ { enum := ord.start(uint32(i)) j := enum.pos*uint32(procs) + enum.inc if checked[j] { println("procs:", procs, "pos:", enum.pos, "inc:", enum.inc)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 01 18:43:08 UTC 2022 - 1.4K bytes - Viewed (0) -
src/runtime/mgclimit_test.go
// // fill + (window * procs * gcBackgroundUtilization - window * procs * (1-gcBackgroundUtilization)) = n // fill = n - (window * procs * gcBackgroundUtilization - window * procs * (1-gcBackgroundUtilization)) // fill = n + window * procs * ((1-gcBackgroundUtilization) - gcBackgroundUtilization) // fill = n + window * procs * (1-2*gcBackgroundUtilization) // window = (fill - n) / (procs * (1-2*gcBackgroundUtilization))) //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 13 16:02:20 UTC 2022 - 9K bytes - Viewed (0) -
pkg/kubelet/stats/pidlimit/pidlimit_linux.go
// https://github.com/kubernetes/kubernetes/issues/107107 if procs, err := runningTaskCount(); err == nil { rlimit.NumOfRunningProcesses = &procs } else { var info syscall.Sysinfo_t syscall.Sysinfo(&info) procs := int64(info.Procs) rlimit.NumOfRunningProcesses = &procs } rlimit.Time = v1.NewTime(time.Now()) return rlimit, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Sep 17 09:24:29 UTC 2023 - 2.4K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/gc-stress.go
for i := range ballast { ballast[i] = new([1024]*node) for j := range ballast[i] { ballast[i][j] = &node{ data: [128]byte{1, 2, 3, 4}, } } } procs := runtime.GOMAXPROCS(-1) sink = make([][]byte, procs) for i := 0; i < procs; i++ { i := i go func() { for { sink[i] = make([]byte, 4<<10) } }() } // Increase the chance that we end up starting and stopping
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 1.5K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/futile-wakeup.go
} defer runtime.GOMAXPROCS(runtime.GOMAXPROCS(8)) c0 := make(chan int, 1) c1 := make(chan int, 1) c2 := make(chan int, 1) const procs = 2 var done sync.WaitGroup done.Add(4 * procs) for p := 0; p < procs; p++ { const iters = 1e3 go func() { trace.WithRegion(context.Background(), "special", func() { for i := 0; i < iters; i++ { runtime.Gosched() c0 <- 0
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 1.8K bytes - Viewed (0) -
src/syscall/exec_plan9.go
// running process to exit. func WaitProcess(pid int, w *Waitmsg) (err error) { procs.Lock() ch := procs.waits[pid] procs.Unlock() var wmsg *waitErr if ch != nil { wmsg = <-ch procs.Lock() if procs.waits[pid] == ch { delete(procs.waits, pid) } procs.Unlock() } if wmsg == nil { // ch was missing or ch is closed return NewError("process not found")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 21:03:59 UTC 2024 - 13.3K bytes - Viewed (0) -
pilot/pkg/features/tuning.go
"If set to 0 or unset, the max will be automatically determined based on the machine size", ).Get() if v > 0 { return v } procs := runtime.GOMAXPROCS(0) // Heuristic to scale with cores. We end up with... // 1: 20 // 2: 25 // 4: 35 // 32: 100 return min(15+5*procs, 100) }() RequestLimit = func() float64 { v := env.Register( "PILOT_MAX_REQUESTS_PER_SECOND", 0.0,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 04:22:19 UTC 2024 - 4.8K bytes - Viewed (1) -
src/internal/trace/gc.go
series = len(out) out = append(out, []MutatorUtil{{int64(ev.Time()), 1}}) } ps = append(ps, perP{series: series}) } if len(procs) == 0 || gomaxprocs != procs[len(procs)-1].n { procs = append(procs, procsCount{time: int64(ev.Time()), n: gomaxprocs}) } } if len(ps) == 0 { // We can't start doing any analysis until we see what GOMAXPROCS is.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 26K bytes - Viewed (0) -
src/testing/benchmark_test.go
} testing.Benchmark(func(b *testing.B) { procs := uint32(0) iters := uint64(0) b.SetParallelism(3) b.RunParallel(func(pb *testing.PB) { atomic.AddUint32(&procs, 1) for pb.Next() { atomic.AddUint64(&iters, 1) } }) if want := uint32(3 * runtime.GOMAXPROCS(0)); procs != want { t.Errorf("got %v procs, want %v", procs, want) } if iters != uint64(b.N) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 5.6K bytes - Viewed (0) -
src/runtime/chan_test.go
<-myc } } }) } func benchmarkChanSync(b *testing.B, work int) { const CallsPerSched = 1000 procs := 2 N := int32(b.N / CallsPerSched / procs * procs) c := make(chan bool, procs) myc := make(chan int) for p := 0; p < procs; p++ { go func() { for { i := atomic.AddInt32(&N, -1) if i < 0 { break } for g := 0; g < CallsPerSched; g++ {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Oct 31 20:47:35 UTC 2023 - 23.4K bytes - Viewed (0)