- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 1,348 for executors (0.24 sec)
-
guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java
ScheduledExecutorService executor = newScheduledThreadPool(1); try { FluentFuture<?> f = FluentFuture.from(SettableFuture.create()).withTimeout(0, SECONDS, executor); ExecutionException e = assertThrows(ExecutionException.class, () -> f.get()); assertThat(e).hasCauseThat().isInstanceOf(TimeoutException.class); } finally { executor.shutdown(); } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 5.7K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/executer/GradleContextualExecuter.java
public static boolean isConfigCache() { Executer executer = getSystemPropertyExecuter(); return executer == Executer.configCache || executer == Executer.isolatedProjects; } public static boolean isNotIsolatedProjects() { return !isIsolatedProjects(); } public static boolean isIsolatedProjects() { return getSystemPropertyExecuter() == Executer.isolatedProjects; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 09 18:06:31 UTC 2024 - 7.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ListeningExecutorService.java
* MoreExecutors#listeningDecorator(ExecutorService)}. * * @author Chris Povirk * @since 10.0 */ @DoNotMock( "Use TestingExecutors.sameThreadScheduledExecutor, or wrap a real Executor from " + "java.util.concurrent.Executors with MoreExecutors.listeningDecorator") @GwtIncompatible @ElementTypesAreNonnullByDefault public interface ListeningExecutorService extends ExecutorService { /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 26 20:33:25 UTC 2023 - 5.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionList.java
+ runnable + " with executor " + executor, e); } } private static final class RunnableExecutorPair { final Runnable runnable; final Executor executor; @CheckForNull RunnableExecutorPair next; RunnableExecutorPair( Runnable runnable, Executor executor, @CheckForNull RunnableExecutorPair next) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 22 21:17:24 UTC 2024 - 6.9K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/http/HcHttpClientTest.java
} // public void test_doGet_mt() throws Exception { // ExecutorService executorService = Executors.newFixedThreadPool(1); // // // HttpClient Parameters // Map<String, Object> paramMap = new HashMap<String, Object>(); // httpClient.setInitParameterMap(paramMap); //
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu May 09 09:28:25 UTC 2024 - 8.8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ExecutionList.java
+ runnable + " with executor " + executor, e); } } private static final class RunnableExecutorPair { final Runnable runnable; final Executor executor; @CheckForNull RunnableExecutorPair next; RunnableExecutorPair( Runnable runnable, Executor executor, @CheckForNull RunnableExecutorPair next) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 22 21:17:24 UTC 2024 - 6.9K bytes - Viewed (0) -
SECURITY.md
## Multi-Tenant environments It is possible to run multiple TensorFlow models in parallel. For example, `ModelServer` collates all computation graphs exposed to it (from multiple `SavedModel`) and executes them in parallel on available executors. Running TensorFlow in a multitenant design mixes the risks described above with the inherent ones from multitenant configurations. The primary areas of concern are
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sun Oct 01 06:06:35 UTC 2023 - 9.6K bytes - Viewed (0) -
maven-core/lifecycle-executor.txt
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Mon Jul 18 17:22:19 UTC 2022 - 9.7K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/DefaultConditionalExecutionQueue.java
this.workerLimits = workerLimits; this.workerLeaseService = workerLeaseService; this.executor = executorFactory.create(displayName); executor.setKeepAlive(KEEP_ALIVE_TIME_MS, TimeUnit.MILLISECONDS); } @Override public void submit(ConditionalExecution<T> execution) { if (queueState == QueueState.Stopped) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:40 UTC 2024 - 7.2K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/CrossVersionIntegrationSpec.groovy
} GradleExecuter version(GradleDistribution dist) { def executer = dist.executer(temporaryFolder, IntegrationTestBuildContext.INSTANCE) if (gradleUserHomeDir) { executer.withGradleUserHomeDir(gradleUserHomeDir) } executer.inDirectory(testDirectory) executers << executer return executer }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 3.5K bytes - Viewed (0)