- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 350 for waitms (0.53 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
waiter2.join(); } public void testRemoveWaiter_polling() throws Exception { final AbstractFuture<String> future = new AbstractFuture<String>() {}; WaiterThread waiter = new WaiterThread(future); waiter.start(); waiter.awaitWaiting(); PollingThread poller = new PollingThread(future); poller.start(); PollingThread poller2 = new PollingThread(future); poller2.start();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 46.7K bytes - Viewed (0) -
cmd/kubeadm/app/util/dryrun/dryrun.go
} return errorsutil.NewAggregate(errs) } // Waiter is an implementation of apiclient.Waiter that should be used for dry-running type Waiter struct{} // NewWaiter returns a new Waiter object that talks to the given Kubernetes cluster func NewWaiter() apiclient.Waiter { return &Waiter{} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 6.5K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/execution/plan/edges/NodeDependencySetTest.groovy
class NodeDependencySetTest extends Specification { def node = Stub(Node) def set = new DependencySuccessorsOnlyNodeSet() def "does not wait when the set is empty"() { expect: set.getState(node) == Node.DependenciesState.COMPLETE_AND_SUCCESSFUL } def "waits until all dependencies have completed successfully"() { def dep1 = Stub(Node) def dep2 = Stub(Node) given:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 12 20:17:10 UTC 2022 - 2.7K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/phases/join/waitcontrolplane.go
klog.V(5).Infof("[wait-control-plane] Skipping phase as the feature gate WaitForAllControlPlaneComponents is disabled") return nil } waiter, err := newControlPlaneWaiter(data.DryRun(), 0, nil, data.OutputWriter()) if err != nil { return errors.Wrap(err, "error creating waiter") } waiter.SetTimeout(data.Cfg().Timeouts.ControlPlaneComponentHealthCheck.Duration)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 15:33:38 UTC 2024 - 2.8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Service.java
void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException; /** * Waits for the {@link Service} to reach the {@linkplain State#TERMINATED terminated state}. * * @throws IllegalStateException if the service {@linkplain State#FAILED fails}. * @since 15.0 */ void awaitTerminated(); /** * Waits for the {@link Service} to reach a terminal state (either {@link Service.State#TERMINATED
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 12.1K bytes - Viewed (0) -
src/os/pidfd_linux.go
handle, status := p.handleTransientAcquire() switch status { case statusDone: // Process already completed Wait, or was not found by // pidfdFind. Return ECHILD for consistency with what the wait // syscall would return. return nil, NewSyscallError("wait", syscall.ECHILD) case statusReleased: return nil, syscall.EINVAL } defer p.handleTransientRelease() var (
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 18:08:44 UTC 2024 - 4.2K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/testing/GcFinalization.java
// TODO(user): Consider scaling by number of mutator threads, // e.g. using Thread#activeCount() return Math.max(10L, Runtime.getRuntime().totalMemory() / (32L * 1024L * 1024L)); } /** * Waits until the given future {@linkplain Future#isDone is done}, invoking the garbage collector * as necessary to try to ensure that this will happen. * * @throws RuntimeException if timed out or interrupted while waiting
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 17:40:56 UTC 2024 - 11.6K bytes - Viewed (0) -
pilot/pkg/xds/deltaadstest.go
} return nil } // ExpectError waits until an error is received and returns it func (a *DeltaAdsTest) ExpectError() error { a.t.Helper() select { case <-time.After(a.timeout): a.t.Fatalf("did not get error in time") case err := <-a.error: return err } return nil } // ExpectNoResponse waits a short period of time and ensures no response is received
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Feb 04 03:39:42 UTC 2024 - 6.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/ready.go
if ok && r.state == Pending { r.state = Ready r.generation++ select { case <-r.waitCh: default: close(r.waitCh) } } else if !ok && r.state == Ready { // creating the waitCh can be racy if // something enter the wait() method select { case <-r.waitCh: r.restartLock.Lock() r.waitCh = make(chan struct{}) r.restartLock.Unlock() default: } r.state = Pending }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 16 13:32:11 UTC 2023 - 4.1K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/GcFinalization.java
// TODO(user): Consider scaling by number of mutator threads, // e.g. using Thread#activeCount() return Math.max(10L, Runtime.getRuntime().totalMemory() / (32L * 1024L * 1024L)); } /** * Waits until the given future {@linkplain Future#isDone is done}, invoking the garbage collector * as necessary to try to ensure that this will happen. * * @throws RuntimeException if timed out or interrupted while waiting
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 17:40:56 UTC 2024 - 11.6K bytes - Viewed (0)