- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 2,355 for nwait (0.12 sec)
-
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r25/ContinuousBuildCancellationCrossVersionSpec.groovy
def latch = new CountDownLatch(1) cancellationToken.addCallback { latch.countDown() } gradle.taskGraph.whenReady { ${server.callFromBuild('sync')} latch.await() } """ } def "logging does not include message to use ctrl-d to exit"() { when: runBuild { succeeds() cancel() } then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 2.9K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/deployment/internal/DefaultContinuousExecutionGate.java
} @Override public void waitForOpen() { lock.lock(); try { if (!gatekeepers.isEmpty()) { while (isClosed()) { // wait for it to open opened.await(); } } } catch (InterruptedException e) { throw UncheckedException.throwAsUncheckedException(e); } finally { lock.unlock();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 3.2K bytes - Viewed (0) -
platforms/core-execution/workers/src/integTest/groovy/org/gradle/workers/internal/WorkQueueIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:36:27 UTC 2023 - 8.7K bytes - Viewed (0) -
platforms/core-execution/workers/src/main/java/org/gradle/workers/internal/NoIsolationWorkerFactory.java
} }); } finally { //TODO the async work tracker should wait for children of an operation to finish first. //It should not be necessary to call it here. workerExecutor.await(); } return result; }); } }; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 08 15:17:07 UTC 2024 - 3.7K bytes - Viewed (0) -
src/os/exec/exec_posix_test.go
if err := cmd.Process.Signal(syscall.SIGSTOP); err != nil { cmd.Process.Kill() t.Fatal(err) } ch := make(chan error) go func() { ch <- cmd.Wait() }() // Give a little time for Wait to block on waiting for the process. // (This is just to give some time to trigger the bug; it should not be // necessary for the test to pass.) if testing.Short() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 13 20:21:32 UTC 2022 - 6.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ConnectionCoalescingTest.kt
call: Call, inetSocketAddress: InetSocketAddress, proxy: Proxy, ) { try { // Wait for request2 to guarantee we make 2 separate connections to the server. latch1.await() } catch (e: InterruptedException) { throw AssertionError(e) } } override fun connectionAcquired(
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 18.7K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/DefaultConditionalExecutionQueue.java
try { workAvailable.await(); } catch (InterruptedException e) { throw UncheckedException.throwAsUncheckedException(e); } } } finally { lock.unlock(); } return getReadyExecution();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:40 UTC 2024 - 7.2K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/util/internal/DisconnectableInputStream.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 07 08:18:46 UTC 2021 - 6.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java
/** Invokes {@code latch.}{@link CountDownLatch#await() await()} uninterruptibly. */ @J2ktIncompatible @GwtIncompatible // concurrency public static void awaitUninterruptibly(CountDownLatch latch) { boolean interrupted = false; try { while (true) { try { latch.await(); return; } catch (InterruptedException e) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 14.4K bytes - Viewed (0) -
pkg/queue/delay.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 20 06:27:31 UTC 2023 - 6.7K bytes - Viewed (0)