- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 922 for Await (0.38 sec)
-
guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
public @Nullable Void call() throws InterruptedException { running = true; startLatch.countDown(); stopLatch.await(); running = false; return null; } public void waitForStart() throws InterruptedException { startLatch.await(); } public void stop() { stopLatch.countDown(); } public boolean isRunning() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 16.8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Monitor.java
*/ @GuardedBy("lock") private void await(Guard guard, boolean signalBeforeWaiting) throws InterruptedException { if (signalBeforeWaiting) { signalNextWaiter(); } beginWaitingFor(guard); try { do { guard.condition.await(); } while (!guard.isSatisfied()); } finally { endWaitingFor(guard); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 18:22:01 UTC 2023 - 42.5K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/DefaultExecHandle.java
while (stateIn(ExecHandleState.STARTING)) { LOGGER.debug("Waiting until process started: {}.", displayName); try { stateChanged.await(); } catch (InterruptedException e) { execHandleRunner.abortProcess(); throw UncheckedException.throwAsUncheckedException(e); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 26 14:58:23 UTC 2024 - 15.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java
lock.lock(); try { locked.countDown(); finishLatch.await(1, TimeUnit.MINUTES); } catch (InterruptedException e) { fail(e.toString()); } finally { lock.unlock(); } } void waitUntilHoldingLock() throws InterruptedException { locked.await(1, TimeUnit.MINUTES); } void releaseLockAndFinish() throws InterruptedException {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 16.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java
lock.lock(); try { locked.countDown(); finishLatch.await(1, TimeUnit.MINUTES); } catch (InterruptedException e) { fail(e.toString()); } finally { lock.unlock(); } } void waitUntilHoldingLock() throws InterruptedException { locked.await(1, TimeUnit.MINUTES); } void releaseLockAndFinish() throws InterruptedException {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 16.1K bytes - Viewed (0) -
src/syscall/exec_plan9.go
if n > 0 { err = NewError(string(errbuf[:n])) } else if err == nil { err = NewError("failed to read exec status") } // Child failed; wait for it to exit, to make sure // the zombies don't accumulate. for wmsg.Pid != pid { Await(&wmsg) } return 0, err } // Read got EOF, so pipe closed on exec, so exec succeeded. return pid, nil } type waitErr struct {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 21:03:59 UTC 2024 - 13.3K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/ConcurrentTestUtil.groovy
withLock { started = true condition.signalAll() } } withLock { while (startThread == null) { condition.await() } } } private void doFinish() { withLock { if (completed) { throw new IllegalStateException("Cannot run async action multiple times.")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 22.9K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction_test.go
// await until controller.taintedNodes is empty err := wait.PollImmediate(10*time.Millisecond, time.Second, func() (bool, error) { controller.taintedNodesLock.Lock() defer controller.taintedNodesLock.Unlock() _, ok := controller.taintedNodes["node1"] return !ok, nil }) if err != nil { t.Errorf("Failed to await for processing node deleted: %q", err) } cancel() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 31.3K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/DefaultFileLockManager.java
private int waiting; @SuppressWarnings("WaitNotInLoop") @Override public boolean await(long millis) throws InterruptedException { lock.lock(); try { waiting++; return condition.await(millis, MILLISECONDS); } finally { waiting--; lock.unlock(); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 26 16:02:32 UTC 2024 - 22.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
if (!streams.containsKey(streamId)) { throw IOException("stream closed") } condition.await() // Wait until we receive a WINDOW_UPDATE. } } catch (e: InterruptedException) { Thread.currentThread().interrupt() // Retain interrupted status. throw InterruptedIOException() }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 32.6K bytes - Viewed (0)