- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 414 for executors (0.14 sec)
-
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
} } val logger = Logger.getLogger("TaskFaker." + instance++) /** Though this executor service may hold many threads, they are not executed concurrently. */ private val tasksExecutor = Executors.newCachedThreadPool(threadFactory("TaskFaker")) /** * True if this task faker has ever had multiple tasks scheduled to run concurrently. Guarded by
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 12.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
ExecutorService executor = newFixedThreadPool(1); requestInterruptIn(500); executor.execute(new SleepTask(1000)); executor.shutdown(); assertTrue(awaitTerminationUninterruptibly(executor, LONG_DELAY_MS, MILLISECONDS)); assertTrue(executor.isTerminated()); assertInterrupted(); } public void testTryAwaitTerminationUninterruptiblyLongTimeUnit_failure() { ExecutorService executor = newFixedThreadPool(1);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 16:06:39 UTC 2024 - 31.7K bytes - Viewed (0) -
tensorflow/c/eager/c_api_experimental.h
TF_Status* status); // Sync pending nodes in local executors (including the context default executor // and thread executors) and streaming requests to remote executors, and get the // combined status. TF_CAPI_EXPORT extern void TFE_ContextAsyncWait(TFE_Context* ctx, TF_Status* status);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Feb 21 22:37:46 UTC 2024 - 39.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java
import java.util.List; import java.util.Locale; import java.util.Map; import java.util.Set; 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 javax.annotation.PostConstruct; import javax.annotation.PreDestroy; import javax.servlet.http.HttpServletRequest;
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 16.5K bytes - Viewed (0) -
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) -
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) -
tensorflow/cc/saved_model/loader.cc
// // Each call to Session::Run() that identifies a new subgraph (based on feeds // and fetches) creates some datastructures that live as long as the session // (the partitioned graph, associated executors etc.). // // A pathological case of this would be if say the initialization op // (main_op/legacy_init_op) involves the use of a large constant. Then we
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Apr 02 04:36:00 UTC 2024 - 23K bytes - Viewed (0)