- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,008 for waits (0.1 sec)
-
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) -
platforms/core-runtime/process-services/src/main/java/org/gradle/process/internal/ExecHandle.java
ExecHandleState getState(); /** * Aborts the process, blocking until the process has exited. Does nothing if the process has already completed. */ void abort(); /** * Waits for the process to finish. Returns immediately if the process has already completed. * * @return result */ ExecResult waitForFinish(); /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 19 21:45:01 UTC 2024 - 1.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_test_context.go
// Depending upon object type, waits afterward until the object is synced // by the policy source func (p *PolicyTestContext[P, B, E]) update(wait bool, objects ...runtime.Object) error { for _, object := range objects { if err := p.updateOne(object); err != nil { return err } } if wait { timeoutCtx, timeoutCancel := context.WithTimeout(p, 3*time.Second)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 19K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/ConcurrentTestUtil.groovy
* * <p>Provides some fixtures for testing:</p> * * <ul> * <li>An action starts another action asynchronously without waiting for the result.</li> * <li>An action starts another action asynchronously and waits for the result.</li> * </ul> */ class ConcurrentTestUtil extends ExternalResource { private static final Logger LOG = LoggerFactory.getLogger(ConcurrentTestUtil.class) private Lock lock = new ReentrantLock()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 22.9K bytes - Viewed (0) -
src/time/sleep.go
// when f will run, in which case Reset returns true, or schedules f // to run again, in which case it returns false. // When Reset returns false, Reset neither waits for the prior f to // complete before returning nor does it guarantee that the subsequent // goroutine running f does not run concurrently with the prior // one. If the caller needs to know whether the prior execution of
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 04 14:21:30 UTC 2024 - 8.5K bytes - Viewed (0) -
tensorflow/compiler/jit/device_compiler_client.h
virtual StatusOr<std::unique_ptr<ExecutableType>> LoadExecutable( const XlaCompiler::Options& options, const XlaCompiler::CompilationResult& result, const std::string& serialized_executable) = 0; // Waits for the underlying `ClientType` backend's programs to finish // executing before returning. virtual void WaitForProgramsToFinish() = 0; virtual ClientType* client() const = 0; private:
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 22 06:59:07 UTC 2024 - 2.8K 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) -
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: Thu Feb 22 17:15:24 UTC 2024 - 37.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ServiceManager.java
} return this; } /** * Waits for the all the services to reach a terminal state. After this method returns all * services will either be {@linkplain Service.State#TERMINATED terminated} or {@linkplain * Service.State#FAILED failed}. */ public void awaitStopped() { state.awaitStopped(); } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:41:16 UTC 2024 - 33K bytes - Viewed (0) -
pkg/envoy/agent.go
type exitStatus struct { err error } // Run starts the envoy and waits until it terminates. // There are a few exit paths: // 1. Envoy exits. In this case, we simply log and exit. // 2. /quitquitquit (on agent, not Envoy) is called. We will set skipDrain and cancel the context, which triggers us to exit immediately.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 24 16:04:22 UTC 2024 - 9K bytes - Viewed (0)