- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 806 for executors (0.19 sec)
-
build-logic-commons/basics/src/main/kotlin/gradlebuild/basics/BuildParams.kt
val Project.defaultPerformanceBaselines: Provider<String> get() = gradleProperty(DEFAULT_PERFORMANCE_BASELINES) // null means no limit: use all available executors val Project.maxTestDistributionRemoteExecutors: Int? get() = gradleProperty(MAX_TEST_DISTRIBUTION_REMOTE_EXECUTORS).orNull?.toInt() val Project.maxTestDistributionLocalExecutors: Int?
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 04 06:42:07 UTC 2024 - 16.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
fail(); } throw new MyError(); } }; } // TODO(cpovirk): top-level class? static class ExecutorSpy implements Executor { Executor delegate; boolean wasExecuted; public ExecutorSpy(Executor delegate) { this.delegate = delegate; } @Override public void execute(Runnable command) { delegate.execute(command);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 144.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
fail(); } throw new MyError(); } }; } // TODO(cpovirk): top-level class? static class ExecutorSpy implements Executor { Executor delegate; boolean wasExecuted; public ExecutorSpy(Executor delegate) { this.delegate = delegate; } @Override public void execute(Runnable command) { delegate.execute(command);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 144.1K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/internal/changedetection/rules/OverlappingOutputsIntegrationTest.groovy
// Use max-workers=1 to force non-parallel execution and the tasks to run in the specified order // (--no-parallel doesn't have an effect with CC, but max-workers should affect both CC and parallel executors) args("--max-workers=1") return super.withBuildCache() }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 20:54:14 UTC 2024 - 30K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
* * @param listener the listener to run when the manager changes state * @param executor the executor in which the listeners callback methods will be run. */ public void addListener(Listener listener, Executor executor) { state.addListener(listener, executor); } /** * Initiates service {@linkplain Service#startAsync startup} on all the services being managed. It
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:41:16 UTC 2024 - 31.1K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ServiceManager.java
* * @param listener the listener to run when the manager changes state * @param executor the executor in which the listeners callback methods will be run. */ public void addListener(Listener listener, Executor executor) { state.addListener(listener, executor); } /** * Initiates service {@linkplain Service#startAsync startup} on all the services being managed. It
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:41:16 UTC 2024 - 33K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
server.enqueue(MockResponse(body = "A")) server.enqueue(MockResponse(body = "A")) val executor = Executors.newCachedThreadPool(threadFactory("HttpOverHttp2Test")) val countDownLatch = CountDownLatch(2) executor.execute(AsyncRequest("/r1", countDownLatch)) executor.execute(AsyncRequest("/r2", countDownLatch)) countDownLatch.await() assertThat(server.takeRequest().sequenceNumber).isEqualTo(0)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 75.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
* <li>All threads generated must be joined inside each test case method (or {@code fail} to do * so) before returning from the method. The {@code joinPool} method can be used to do this * when using Executors. * </ol> * * <p><b>Other notes</b> * * <ul> * <li>Usually, there is one testcase method per JSR166 method covering "normal" operation, and
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 19:21:11 UTC 2024 - 37.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
} try { closingFuture.finishToValueAndCloser(new NoOpValueAndCloserConsumer<>(), executor); fail(); } catch (IllegalStateException expected) { } } // Avoid infinite recursion if a closeable's close() method throws RejectedExecutionException and // is closed using the direct executor. public void testCloseThrowsRejectedExecutionException() throws Exception {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 75.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
} try { closingFuture.finishToValueAndCloser(new NoOpValueAndCloserConsumer<>(), executor); fail(); } catch (IllegalStateException expected) { } } // Avoid infinite recursion if a closeable's close() method throws RejectedExecutionException and // is closed using the direct executor. public void testCloseThrowsRejectedExecutionException() throws Exception {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 75.3K bytes - Viewed (0)