- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 2,328 for executors (0.12 sec)
-
android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
* fails}. */ protected ScheduledExecutorService executor() { @WeakOuter class ThreadFactoryImpl implements ThreadFactory { @Override public Thread newThread(Runnable runnable) { return MoreExecutors.newThread(serviceName(), runnable); } } final ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor(new ThreadFactoryImpl());
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 13 19:45:20 UTC 2023 - 25.8K 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) -
guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
* fails}. */ protected ScheduledExecutorService executor() { @WeakOuter class ThreadFactoryImpl implements ThreadFactory { @Override public Thread newThread(Runnable runnable) { return MoreExecutors.newThread(serviceName(), runnable); } } final ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor(new ThreadFactoryImpl());
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 13 19:45:20 UTC 2023 - 27.5K 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) -
tensorflow/c/eager/immediate_execution_context.h
virtual void EndStep() = 0; // Return the Eager Executor for current thread. Please note that Eager // Executor is only used in current TF but not in TFRT. virtual EagerExecutor& Executor() = 0; // Update the Eager Executor for current thread. virtual void SetExecutorForThread(EagerExecutor* executor) = 0; // Return a list of local tensorflow::Device*.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Jul 06 08:34:00 UTC 2023 - 12.3K 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) -
guava-tests/test/com/google/common/collect/QueuesTest.java
import static com.google.common.truth.Truth.assertThat; import static java.lang.Long.MAX_VALUE; import static java.lang.Thread.currentThread; import static java.util.concurrent.Executors.newCachedThreadPool; import static java.util.concurrent.TimeUnit.MILLISECONDS; import static java.util.concurrent.TimeUnit.NANOSECONDS; import static java.util.concurrent.TimeUnit.SECONDS;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 12K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/QueuesTest.java
import static com.google.common.truth.Truth.assertThat; import static java.lang.Long.MAX_VALUE; import static java.lang.Thread.currentThread; import static java.util.concurrent.Executors.newCachedThreadPool; import static java.util.concurrent.TimeUnit.MILLISECONDS; import static java.util.concurrent.TimeUnit.NANOSECONDS; import static java.util.concurrent.TimeUnit.SECONDS;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 12K 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) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
/** Synchronization control for AbstractFutures. */ private final Sync<V> sync = new Sync<V>(); // The execution list to hold our executors. private final ExecutionList executionList = new ExecutionList(); /** Constructor for use by subclasses. */ protected OldAbstractFuture() {} /*
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Apr 06 12:56:11 UTC 2023 - 13.6K bytes - Viewed (0)