- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 2,050 for Await (0.04 sec)
-
platforms/core-configuration/kotlin-dsl/src/test/kotlin/org/gradle/kotlin/dsl/concurrent/DefaultAsyncIOScopeFactoryTest.kt
* limitations under the License. */ package org.gradle.kotlin.dsl.concurrent import org.awaitility.Duration.ONE_SECOND import org.awaitility.kotlin.atMost import org.awaitility.kotlin.await import org.awaitility.kotlin.untilNotNull import org.gradle.kotlin.dsl.support.useToRun import org.hamcrest.CoreMatchers.equalTo import org.hamcrest.CoreMatchers.instanceOf
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Aug 02 08:06:49 UTC 2023 - 3.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
// WAIT #1 barrier.await(1, TimeUnit.SECONDS); // WAIT #2 barrier.await(1, TimeUnit.SECONDS); assertTrue(executor.isShutdown()); assertFalse(executor.isTerminated()); // WAIT #3
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 28.2K 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/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r86/StreamingBuildActionCrossVersionTest.groovy
collectOutputs(builder) builder.setStreamedValueListener(listener) builder.run(handler) modelReceived.await() request.waitForAllPendingCalls() request.releaseAll() finished.await() } then: models.size() == 2 models[0] instanceof GradleProject models[1] instanceof CustomModel }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Mar 07 03:20:59 UTC 2024 - 6.9K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/testing/GcFinalization.java
* Object x = new MyClass() { * ... * protected void finalize() { latch.countDown(); ... } * }; * x = null; // Hint to the JIT that x is stack-unreachable * GcFinalization.await(latch); * }</pre> * * <p>Here's an example that uses a user-defined finalization predicate: * * <pre>{@code * final WeakHashMap<Object, Object> map = new WeakHashMap<>(); * map.put(new Object(), Boolean.TRUE);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 17:40:56 UTC 2024 - 11.6K bytes - Viewed (0) -
platforms/core-execution/workers/src/test/groovy/org/gradle/workers/internal/DefaultWorkerExecutorParallelTest.groovy
} def "can wait on results to complete"() { when: workerExecutor.await() then: 1 * asyncWorkerTracker.waitForCompletion(_, RETAIN_PROJECT_LOCKS) } def "all errors are thrown when waiting on multiple results"() { when: workerExecutor.await() then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Mar 25 14:22:31 UTC 2024 - 6.5K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/internal/operations/DefaultBuildOperationQueueTest.groovy
operationQueue.waitForCompletion() } }) waitForCompletionThread.start() and: // wait for operations to begin running startedLatch.await(30, TimeUnit.SECONDS) and: operationQueue.cancel() and: // release the running operations to complete releaseLatch.countDown()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 9.4K bytes - Viewed (0) -
fastapi/dependencies/utils.py
elif is_gen_callable(call) or is_async_gen_callable(call): solved = await solve_generator( call=call, stack=async_exit_stack, sub_values=sub_values ) elif is_coroutine_callable(call): solved = await call(**sub_values) else: solved = await run_in_threadpool(call, **sub_values) if sub_dependant.name is not None:
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Tue Apr 02 02:52:56 UTC 2024 - 29.5K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/SendPartialResponseThenBlock.java
condition.signalAll(); throw failure; } try { condition.await(waitMs, TimeUnit.MILLISECONDS); } catch (InterruptedException e) { throw UncheckedException.throwAsUncheckedException(e); } } if (failure != null) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 4.7K bytes - Viewed (0) -
maven-embedder/src/test/java/org/apache/maven/cli/transfer/ConsoleMavenTransferListenerTest.java
}); } // start all threads at once try { startLatch.await(); } catch (InterruptedException e) { e.printStackTrace(); } // wait for all thread to end try { endLatch.await(); } catch (InterruptedException e) { e.printStackTrace(); }
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Feb 28 23:31:59 UTC 2024 - 5K bytes - Viewed (0)