- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,183 for waitc (0.1 sec)
-
guava/src/com/google/common/util/concurrent/MoreExecutors.java
/** * Converts the given ThreadPoolExecutor into an ExecutorService that exits when the application * is complete. It does so by using daemon threads and adding a shutdown hook to wait for their * completion. * * <p>This method waits 120 seconds before continuing with JVM termination, even if the executor * has not finished its work. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 15 10:40:05 UTC 2024 - 43.7K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/operations/BuildOperationQueue.java
*/ void add(T operation); /** * Cancels all queued operations in this queue. Any operations that have started will be allowed to complete. */ void cancel(); /** * Waits for all previously added operations to complete. * <p> * On failure, some effort is made to cancel any operations that have not started. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 2.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
threadUnexpectedException(t); } } // /** // * Spin-waits up to LONG_DELAY_MS until flag becomes true. // */ // public void await(AtomicBoolean flag) { // await(flag, LONG_DELAY_MS); // } // /** // * Spin-waits up to the specified timeout until flag becomes true. // */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 19:21:11 UTC 2024 - 37.7K bytes - Viewed (0) -
cni/pkg/install/cniconfig.go
} installLog.Infof("Created CNI config %s", cniConfigFilepath) installLog.Debugf("CNI config: %s", pluginConfig) return cniConfigFilepath, nil } // If configured as chained CNI plugin, waits indefinitely for a main CNI config file to exist before returning // Or until cancelled by parent context func getCNIConfigFilepath(ctx context.Context, cniConfName, mountedCNINetDir string, chained bool) (string, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 21 18:32:01 UTC 2024 - 8.3K bytes - Viewed (0) -
pkg/controller/volume/pvcprotection/pvc_protection_controller.go
// b) was force-deleted. // // It's now just waiting for garbage collection. We could wait // for it to actually get removed, but that may be blocked by // finalizers for the pod and thus get delayed. // // Worse, it is possible that there is a cyclic dependency // (pod finalizer waits for PVC to get removed, PVC protection // controller waits for pod to get removed). By considering
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 14K bytes - Viewed (0) -
pkg/kubelet/runtimeclass/testing/fake_manager.go
return fake.NewSimpleClientset( NewRuntimeClass(EmptyRuntimeClass, ""), NewRuntimeClass(SandboxRuntimeClass, SandboxRuntimeHandler), ) } // StartManagerSync starts the manager, and waits for the informer cache to sync. // Returns a function to stop the manager, which should be called with a defer: // // defer StartManagerSync(t, m)() func StartManagerSync(m *runtimeclass.Manager) func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 2.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/interface.go
"context" "k8s.io/apimachinery/pkg/labels" "k8s.io/apimachinery/pkg/runtime" "k8s.io/client-go/tools/cache" ) type Controller[T runtime.Object] interface { // Meant to be run inside a goroutine // Waits for and reacts to changes in whatever type the controller // is concerned with. // // Returns an error always non-nil explaining why the worker stopped Run(ctx context.Context) error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 1.9K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/leaderelection.go
// wait to force acquire leadership. This is measured against time of // last observed ack. // // A client needs to wait a full LeaseDuration without observing a change to // the record before it can attempt to take over. When all clients are // shutdown and a new set of clients are started with different names against // the same leader record, they must wait the full LeaseDuration before
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 24 04:04:42 UTC 2023 - 16.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Monitor.java
try { return satisfied = guard.isSatisfied(); } finally { if (!satisfied) { lock.unlock(); } } } /** * Waits for the guard to be satisfied. Waits indefinitely, but may be interrupted. May be called * only by a thread currently occupying this monitor. * * @throws InterruptedException if interrupted while waiting */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 18:22:01 UTC 2023 - 38.6K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/framework_test.go
} oldChanges = changes } } // waitTest waits until all tests, controllers and other goroutines do their // job and list of current volumes/claims is equal to list of expected // volumes/claims (with ~10 second timeout). func (r *volumeReactor) waitTest(test controllerTest) error { // start with 10 ms, multiply by 2 each step, 10 steps = 10.23 seconds backoff := wait.Backoff{ Duration: 10 * time.Millisecond, Jitter: 0,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 09:54:00 UTC 2023 - 38.3K bytes - Viewed (0)