- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 2,355 for nwait (0.03 sec)
-
guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 16:06:39 UTC 2024 - 31.7K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
}) .start(); future.cancel(true); assertTrue(future.isCancelled()); assertTrue(future.isDone()); assertTrue(successLatch.await(200, MILLISECONDS)); assertTrue(listenerLatch.await(200, MILLISECONDS)); latch.countDown(); exec.shutdown(); exec.awaitTermination(100, MILLISECONDS); } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 18:30:30 UTC 2023 - 6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Feb 09 22:57:07 UTC 2022 - 30.9K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/server/DefaultDaemonConnectionTest.groovy
waiting.countDown() result = daemonConnection.receive(20, TimeUnit.SECONDS) received.countDown() } waiting.await() Thread.sleep(500) connection.queueIncoming("incoming") received.await() then: result instanceof Received result.message == "incoming" } def "receive blocks until connection stopped"() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 11.7K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ExpectMaxNConcurrentRequests.java
previous.assertCanWait(); if (notReceived.isEmpty()) { // Have received all requests so downstream can wait. return; } if (!isAutoRelease()) { throw new IllegalStateException(String.format("Cannot wait as no requests have been released. Waiting for %s, received %s.", format(notReceived), format(received))); } } finally {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 14.4K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/dispatch/AsyncDispatch.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 6.7K bytes - Viewed (0) -
platforms/core-configuration/kotlin-dsl/src/test/kotlin/org/gradle/kotlin/dsl/resolver/KotlinBuildScriptModelRepositoryTest.kt
val (_, asyncResp2) = pendingTasks[1] assertThat( asyncResp2.await(), nullValue() ) // only then the most recent request will be given its response assertThat( asyncRespLast.await(), sameInstance(respLast) ) // and no other requests are left to process assertThat(
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Aug 02 08:06:49 UTC 2023 - 6.3K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
}) .start(); future.cancel(true); assertTrue(future.isCancelled()); assertTrue(future.isDone()); assertTrue(successLatch.await(200, MILLISECONDS)); assertTrue(listenerLatch.await(200, MILLISECONDS)); latch.countDown(); exec.shutdown(); exec.awaitTermination(100, MILLISECONDS); } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 18:30:30 UTC 2023 - 6K bytes - Viewed (0) -
src/cmd/go/testdata/script/goroot_executable.txt
os.Exit(1) } want, err = filepath.EvalSymlinks(want) if err != nil { fmt.Fprintln(os.Stderr, err) os.Exit(1) } if !strings.EqualFold(goroot, want) { fmt.Fprintf(os.Stderr, "go env GOROOT:\nhave %s\nwant %s\n", goroot, want) os.Exit(1) } fmt.Fprintf(os.Stderr, "go env GOROOT: %s\n", goroot) } -- check_runtime_goroot.go -- package main import ( "fmt" "os" "path/filepath" "runtime"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Feb 21 22:16:54 UTC 2024 - 2.6K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/operations/DefaultBuildOperationQueue.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jan 31 15:18:20 UTC 2023 - 10.4K bytes - Viewed (0)