- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 2,388 for procMs (0.16 sec)
-
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) -
platforms/core-runtime/native/src/main/java/org/gradle/internal/nativeintegration/processenvironment/NativePlatformBackedProcessEnvironment.java
package org.gradle.internal.nativeintegration.processenvironment; import net.rubygrapefruit.platform.Process; import java.io.File; public class NativePlatformBackedProcessEnvironment extends AbstractProcessEnvironment { private final Process process; public NativePlatformBackedProcessEnvironment(Process process) { this.process = process; } @Override protected void removeNativeEnvironmentVariable(String name) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 1.6K bytes - Viewed (0) -
src/syscall/exec_windows_test.go
} func TestChangingProcessParent(t *testing.T) { if os.Getenv("GO_WANT_HELPER_PROCESS") == "parent" { // in parent process // Parent does nothing. It is just used as a parent of a child process. time.Sleep(time.Minute) os.Exit(0) } if os.Getenv("GO_WANT_HELPER_PROCESS") == "child" { // in child process dumpPath := os.Getenv("GO_WANT_HELPER_PROCESS_FILE") if dumpPath == "" {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 05 23:35:29 UTC 2023 - 3.1K 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 (0) -
platforms/core-execution/workers/src/main/java/org/gradle/workers/IsolationMode.java
*/ AUTO, /** * Don't attempt to isolate the work, use in-process workers. */ NONE, /** * Isolate the work in its own classloader, use in-process workers. */ CLASSLOADER, /** * Isolate the work in a separate process, use out-of-process workers. */ PROCESS
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:36:27 UTC 2023 - 1.1K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/testing/internal/util/GradlewRunner.java
} })); forwardAsync(process.getInputStream(), System.out); forwardAsync(process.getErrorStream(), System.err); process.waitFor(); } catch (IOException e) { e.printStackTrace(); } catch (InterruptedException e) { e.printStackTrace(); process.destroy(); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sun May 12 10:33:12 UTC 2024 - 3.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/config.go
var kmsHealthChecks []healthz.HealthChecker transformers, probes, kmsUsed, err := getTransformerOverridesAndKMSPluginProbes(ctx, config, apiServerID) if err != nil { return nil, nil, nil, err } for i := range probes { probe := probes[i] kmsHealthChecks = append(kmsHealthChecks, probe.toHealthzCheck(i)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 16:56:39 UTC 2024 - 41.2K bytes - Viewed (0) -
architecture/environments/operator.md
resources | [resources](https://kubernetes.io/docs/concepts/configuration/manage-compute-resources-container/#resource-requests-and-limits-of-pod-and-container) readinessProbe | [readiness probes](https://kubernetes.io/docs/tasks/configure-pod-container/configure-liveness-readiness-probes/) replicaCount | [replica count](https://kubernetes.io/docs/concepts/workloads/controllers/deployment/)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 09 22:09:18 UTC 2023 - 13.4K bytes - Viewed (0) -
platforms/core-runtime/process-services/src/main/java/org/gradle/process/internal/ExecHandleBuilder.java
* limitations under the License. */ package org.gradle.process.internal; import org.gradle.process.BaseExecSpec; import org.gradle.process.ExecSpec; import org.gradle.process.ProcessForkOptions; public interface ExecHandleBuilder extends ProcessForkOptions, BaseExecSpec, ExecSpec { /** * Merge the process' error stream into its output stream */ ExecHandleBuilder redirectErrorStream();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:10:02 UTC 2023 - 1.6K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/bootstrap/DaemonOutputConsumer.java
private String processOutput; private InputStream processStdOutput; @Override public void connectStreams(Process process, String processName, Executor executor) { processStdOutput = process.getInputStream(); } @Override @SuppressWarnings("DefaultCharset") public void start() { if (processStdOutput == null) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 2.7K bytes - Viewed (0)