- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 66 for waitc (0.05 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
} /** * Marks the given step final, waits for it to be finished, and returns the value. * * @throws ExecutionException if the step failed * @throws CancellationException if the step was cancelled */ abstract <T> T getFinalValue(ClosingFuture<T> closingFuture) throws ExecutionException; /** Marks the given step final, cancels it, and waits for the cancellation to happen. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 75.3K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller.go
// be re-queued until "Done", so no more than one worker handle the same item and // no event missed. go wait.UntilWithContext(ctx, nc.doNodeProcessingPassWorker, time.Second) } for i := 0; i < podUpdateWorkerSize; i++ { go wait.UntilWithContext(ctx, nc.doPodProcessingWorker, time.Second) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.6K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container.go
gracePeriod = gracePeriod - m.executePreStopHook(ctx, pod, containerID, containerSpec, gracePeriod) } // if we care about termination ordering, then wait for this container's turn to exit if there is // time remaining if ordering != nil && gracePeriod > 0 { // grace period is only in seconds, so the time we've waited gets truncated downward
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 54.7K bytes - Viewed (0) -
src/os/os_test.go
} }() // Note the deferred Wait must be called after the deferred close(done), // to ensure the N goroutines have been released even if the main goroutine // calls Fatalf. It must be called before the Chdir back to the original // directory, and before the deferred deletion implied by TempDir, // so as not to interfere while the N goroutines are still running. defer wg.Wait() defer close(done)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 83.1K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager_test.go
"k8s.io/apimachinery/pkg/api/resource" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/types" "k8s.io/apimachinery/pkg/util/sets" "k8s.io/apimachinery/pkg/util/uuid" "k8s.io/apimachinery/pkg/util/wait" "k8s.io/client-go/tools/record" pluginapi "k8s.io/kubelet/pkg/apis/deviceplugin/v1beta1" watcherapi "k8s.io/kubelet/pkg/apis/pluginregistration/v1" "k8s.io/kubernetes/pkg/kubelet/checkpointmanager"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 65K bytes - Viewed (0) -
cmd/kubelet/app/server.go
} if s.HealthzPort > 0 { mux := http.NewServeMux() healthz.InstallHandler(mux) go wait.Until(func() { err := http.ListenAndServe(net.JoinHostPort(s.HealthzBindAddress, strconv.Itoa(int(s.HealthzPort))), mux) if err != nil { klog.ErrorS(err, "Failed to start healthz server") } }, 5*time.Second, wait.NeverStop) } if s.RunOnce { return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:34 UTC 2024 - 53.9K bytes - Viewed (0) -
src/cmd/go/internal/test/test.go
if i > 0 { a.Deps = append(a.Deps, prints[i-1]) } } // Force benchmarks to run in serial. if !testC && (testBench != "") { // The first run must wait for all builds. // Later runs must wait for the previous run's print. for i, run := range runs { if i == 0 { run.Deps = append(run.Deps, builds...) } else { run.Deps = append(run.Deps, prints[i-1]) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 14:34:32 UTC 2024 - 71.9K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/ratcheting_test.go
"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured" "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/runtime/schema" "k8s.io/apimachinery/pkg/util/uuid" "k8s.io/apimachinery/pkg/util/wait" utilyaml "k8s.io/apimachinery/pkg/util/yaml" utilfeature "k8s.io/apiserver/pkg/util/feature" "k8s.io/client-go/dynamic" featuregatetesting "k8s.io/component-base/featuregate/testing"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 59.5K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 15:22:37 UTC 2024 - 75.9K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/project/DefaultProjectBuilder.java
// We need an executor that will not block. // We can't use work stealing, as we are building a graph // and this could lead to cycles where a thread waits for // a task to finish, then execute another one which waits // for the initial task... // In order to work around that problem, we override the // invokeAll method, so that whenever the method is called,
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Mon May 13 16:34:29 UTC 2024 - 57.1K bytes - Viewed (0)