- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,141 for executors (0.56 sec)
-
src/main/java/org/codelibs/fess/sso/aad/AzureAdAuthenticator.java
import java.util.HashMap; import java.util.List; import java.util.Locale; import java.util.Map; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; import java.util.stream.Collectors; import javax.annotation.PostConstruct; import javax.servlet.http.HttpServletRequest;
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 28.1K 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) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/BlockingHttpServer.java
import java.time.Duration; import java.util.ArrayList; import java.util.Collection; import java.util.Collections; import java.util.List; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; import java.util.logging.ConsoleHandler; import java.util.logging.Level;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 21.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DuplexTest.kt
import java.io.IOException import java.net.HttpURLConnection import java.net.ProtocolException import java.util.concurrent.BlockingQueue import java.util.concurrent.CountDownLatch import java.util.concurrent.Executors import java.util.concurrent.LinkedBlockingQueue import java.util.concurrent.TimeUnit import kotlin.test.assertFailsWith import mockwebserver3.MockResponse import mockwebserver3.MockWebServer
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 23.9K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/internal/tasks/TaskCacheabilityReasonIntegrationTest.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: Thu May 23 16:59:01 UTC 2024 - 17.6K bytes - Viewed (0) -
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)