- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for threadPool (0.15 sec)
-
android/guava-tests/test/com/google/common/collect/QueuesTest.java
* be a SynchronousQueue. */ private ExecutorService threadPool; @Override public void setUp() { threadPool = newCachedThreadPool(); } @Override public void tearDown() throws InterruptedException { threadPool.shutdown(); assertTrue("Some worker didn't finish in time", threadPool.awaitTermination(10, SECONDS)); } private static <T> int drain(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 12K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/QueuesTest.java
* be a SynchronousQueue. */ private ExecutorService threadPool; @Override public void setUp() { threadPool = newCachedThreadPool(); } @Override public void tearDown() throws InterruptedException { threadPool.shutdown(); assertTrue("Some worker didn't finish in time", threadPool.awaitTermination(10, SECONDS)); } private static <T> int drain(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 12K bytes - Viewed (0) -
src/main/java/org/codelibs/curl/CurlRequest.java
} catch (final UnsupportedEncodingException e) { throw new CurlException("Invalid encoding: " + encoding, e); } } public CurlRequest threadPool(final ForkJoinPool threadPool) { this.threadPool = threadPool; return this; } public static class RequestProcessor implements Consumer<HttpURLConnection> { protected CurlResponse response = new CurlResponse();
Registered: Wed Jun 12 08:29:43 UTC 2024 - Last Modified: Sun Feb 12 12:21:25 UTC 2023 - 12.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/Suggester.java
protected final String index; protected final ExecutorService threadPool; public Suggester(final Client client, final SuggestSettings settings, final ReadingConverter readingConverter, final ReadingConverter contentsReadingConverter, final Normalizer normalizer, final SuggestAnalyzer analyzer, final ExecutorService threadPool) { this.client = client; this.suggestSettings = settings;
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 14.6K bytes - Viewed (0) -
tensorflow/compiler/aot/tests/tfcompile_test.cc
TEST(TFCompileTest, VariableReadonly) { Eigen::ThreadPool tp(1); Eigen::ThreadPoolDevice device(&tp, tp.NumThreads()); VariableReadonlyComp fn; float x = 23; fn.set_var_x_data(&x); fn.set_thread_pool(&device); fn.Run(); EXPECT_EQ(fn.result0(), 65); EXPECT_EQ(fn.var_x(), 23); } TEST(TFCompileTest, Variable) { Eigen::ThreadPool tp(1);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Sep 06 19:12:29 UTC 2023 - 26.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java
protected SuggestWriter suggestWriter; protected ExecutorService threadPool; public SuggestIndexer(final Client client, final String index, final ReadingConverter readingConverter, final ReadingConverter contentsReadingConverter, final Normalizer normalizer, final SuggestAnalyzer analyzer, final SuggestSettings settings, final ExecutorService threadPool) { this.client = client; this.index = index;
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 26.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheBuilderTest.java
ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); final CountDownLatch tasksFinished = new CountDownLatch(nTasks); for (int i = 0; i < nTasks; i++) { final String s = "a" + i; @SuppressWarnings("unused") // https://errorprone.info/bugpattern/FutureReturnValueIgnored Future<?> possiblyIgnoredError = threadPool.submit( new Runnable() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Oct 03 20:10:02 UTC 2023 - 23.2K bytes - Viewed (0) -
fess-crawler-es/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 19.8K bytes - Viewed (0) -
tensorflow/compiler/jit/device_compiler.h
#include "tensorflow/compiler/tf2xla/xla_compiler.h" #include "xla/client/local_client.h" #include "tensorflow/core/framework/metrics.h" #include "tensorflow/core/framework/op_kernel.h" #include "tensorflow/core/lib/core/threadpool.h" #include "tensorflow/core/platform/mutex.h" #include "tensorflow/core/platform/thread_annotations.h" namespace tensorflow { // Compiles/lowers a given Tensorflow graph/function/cluster into a compiled XLA
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 22 08:47:20 UTC 2024 - 22.1K bytes - Viewed (0) -
docs/en/docs/how-to/sql-databases-peewee.md
On top of that, an async framework could run some sync code in a threadpool (using `asyncio.run_in_executor`), but belonging to the same request.
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Tue Jan 16 13:23:25 UTC 2024 - 23.6K bytes - Viewed (0)