- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 1,948 for waits (0.04 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) -
src/sync/runtime.go
// defined in package runtime // Semacquire waits until *s > 0 and then atomically decrements it. // It is intended as a simple sleep primitive for use by the synchronization // library and should not be used directly. func runtime_Semacquire(s *uint32) // Semacquire(RW)Mutex(R) is like Semacquire, but for profiling contended // Mutexes and RWMutexes. // If lifo is true, queue waiter at the head of wait queue.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 16 16:32:27 UTC 2022 - 2.3K 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) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/testing/v2/kms_plugin_mock.go
t.Fatalf("failed to start KMS plugin: err: %v", err) } return result } // waitForBase64PluginToBeUp waits until the plugin is ready to serve requests. func waitForBase64PluginToBeUp(plugin *Base64Plugin) error { var gRPCErr error var resp *kmsapi.StatusResponse pollErr := wait.PollImmediate(1*time.Second, wait.ForeverTestTimeout, func() (bool, error) { resp, gRPCErr = plugin.Status(context.Background(), &kmsapi.StatusRequest{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 21 19:25:52 UTC 2023 - 6.5K 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) -
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) -
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)