- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 2,181 for Await (0.16 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java
assertEquals(3L, countDownLatch.getCount()); list.execute(); // Verify that all of the runnables execute in a reasonable amount of time. assertTrue(countDownLatch.await(1L, TimeUnit.SECONDS)); } public void testExecute_idempotent() { final AtomicInteger runCalled = new AtomicInteger(); list.add( new Runnable() { @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Feb 09 22:57:07 UTC 2022 - 4.7K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/internal/operations/MaxWorkersTest.groovy
} } leaseAcquiredLatch.await() // release the first queue to submit its work synchronized (release) { release.notify() } // Wait for all worker leases to be utilized running work runningLatch.await() fullyUtilizedLatch.countDown() } where:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 8.3K bytes - Viewed (0) -
platforms/core-configuration/kotlin-dsl/src/main/kotlin/org/gradle/kotlin/dsl/concurrent/future.kt
override fun isDone(): Boolean = result != null override fun get(): T { outcomeLatch.await() return getOrThrow() } override fun get(timeout: Long, unit: TimeUnit): T = if (outcomeLatch.await(timeout, unit)) getOrThrow() else throw TimeoutException() private fun getOrThrow() = (result as Result<T>).getOrThrow()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Aug 02 08:06:49 UTC 2023 - 2.2K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonStateCoordinator.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 17.1K bytes - Viewed (0) -
platforms/extensibility/unit-test-fixtures/src/integTest/groovy/org/gradle/testfixtures/ProjectBuilderIntegrationTest.groovy
def threads = 5 def startSignal = new CountDownLatch(1) def doneSignal = new CountDownLatch(threads) when: threads.times { new Thread({ startSignal.await() def spawnedProject = ProjectBuilder.builder().build() try { doneSignal.countDown() } finally {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 13 21:54:27 UTC 2024 - 3.5K bytes - Viewed (0) -
docs/ko/docs/async.md
# 동시성과 async / await *경로 작동 함수*에서의 `async def` 문법에 대한 세부사항과 비동기 코드, 동시성 및 병렬성에 대한 배경 ## 바쁘신 경우 <strong>요약</strong> 다음과 같이 `await`를 사용해 호출하는 제3의 라이브러리를 사용하는 경우: ```Python results = await some_library() ``` 다음처럼 *경로 작동 함수*를 `async def`를 사용해 선언하십시오: ```Python hl_lines="2" @app.get('/') async def read_results(): results = await some_library() return results ``` !!! note "참고"
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Apr 18 19:53:19 UTC 2024 - 26.7K bytes - Viewed (0) -
tensorflow/compiler/mlir/tfrt/tests/mlrt/tpu_conversions.mlir
// CHECK: [[recv_future:%.*]] = tf_mlrt.async_executeop.device([[device]]){{.*}}op: \22Recv\22 // CHECK: [[recv:%.*]] = tf_mlrt.await [[recv_future]] // CHECK: [[rendezvous_key_base:%.*]], [[result_future:%.*]] = tf_mlrt_tpu.compile_and_execute([[recv]]) // CHECK: tf_mlrt.await [[result_future]]
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Oct 04 21:25:31 UTC 2023 - 11K 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/DefaultWorkerExecutor.java
workItems.add(workerExecutor.submitWork(workActionClass, parameterAction, spec, workerFactory)); } @Override public void await() throws WorkerExecutionException { workerExecutor.await(workItems); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 08 15:17:07 UTC 2024 - 15.2K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/plan9/syscall_plan9.go
func (w Waitmsg) ExitStatus() int { if len(w.Msg) == 0 { // a normal exit returns no message return 0 } return 1 } //sys await(s []byte) (n int, err error) func Await(w *Waitmsg) (err error) { var buf [512]byte var f [5][]byte n, err := await(buf[:]) if err != nil || w == nil { return } nf := 0 p := 0 for i := 0; i < n && nf < len(f)-1; i++ {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 16 22:24:28 UTC 2022 - 7K bytes - Viewed (0)