- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for threadPool (0.32 sec)
-
src/main/java/org/codelibs/fess/suggest/SuggesterBuilder.java
} public SuggesterBuilder analyzer(final SuggestAnalyzer analyzer) { this.analyzer = analyzer; return this; } public SuggesterBuilder threadPool(final ExecutorService threadPool) { this.threadPool = threadPool; return this; } public SuggesterBuilder threadPoolSize(final int threadPoolSize) { this.threadPoolSize = threadPoolSize; return this; }
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 4.2K bytes - Viewed (0) -
tensorflow/cc/client/client_session_test.cc
{ thread::ThreadPool thread_pool(Env::Default(), "pool", 2); thread_pool.Schedule([&session, a]() { std::vector<Tensor> outputs; TF_EXPECT_OK(session.Run({a}, &outputs)); test::ExpectTensorEqual<int>(outputs[0], test::AsTensor<int>({4, 6}, {2})); }); thread_pool.Schedule([&session, b]() { std::vector<Tensor> outputs;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Sep 06 19:12:29 UTC 2023 - 9.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AtomicLongMapBasherTest.java
final String key = "key"; final AtomicLongMap<String> map = AtomicLongMap.create(); ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); ArrayList<Future<Long>> futures = new ArrayList<>(); for (int i = 0; i < nTasks; i++) { futures.add( threadPool.submit( new Callable<Long>() { @Override public Long call() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 4.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AtomicLongMapBasherTest.java
final String key = "key"; final AtomicLongMap<String> map = AtomicLongMap.create(); ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); ArrayList<Future<Long>> futures = new ArrayList<>(); for (int i = 0; i < nTasks; i++) { futures.add( threadPool.submit( new Callable<Long>() { @Override public Long call() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 4.2K bytes - Viewed (0) -
fastapi/datastructures.py
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Tue Apr 02 02:48:51 UTC 2024 - 5.6K bytes - Viewed (1) -
tensorflow/compiler/aot/test.cc
memset(computation->arg_data(i), 0, computation->arg_size(i)); } } // Trivial test that runs the generated function to ensure it doesn't crash. TEST(TEST_NAME, NoCrash) { Eigen::ThreadPool pool(port::MaxParallelism()); Eigen::ThreadPoolDevice device(&pool, pool.NumThreads()); CPP_CLASS computation; computation.set_thread_pool(&device); zero_buffers(&computation);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Sep 06 19:12:29 UTC 2023 - 3K bytes - Viewed (0) -
tensorflow/compiler/aot/test_google.cc
memset(computation->arg_data(i), 0, computation->arg_size(i)); } } // Trivial test that runs the generated function to ensure it doesn't crash. TEST(TEST_NAME, NoCrash) { Eigen::ThreadPool pool(port::MaxParallelism()); Eigen::ThreadPoolDevice device(&pool, pool.NumThreads()); CPP_CLASS computation; computation.set_thread_pool(&device); zero_buffers(&computation);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Sep 06 19:12:29 UTC 2023 - 3K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_device_context.h
std::vector<std::shared_ptr<se::Stream>> device_to_device_streams, xla::LocalClient* client, XlaShapeLayoutHelpers::ShapeDeterminationFns shape_determination_fns, thread::ThreadPool* thread_pool); void CopyCPUTensorToDevice(const Tensor* cpu_tensor, Device* device, Tensor* device_tensor, StatusCallback done, bool sync_dst_compute) const override;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Sep 06 19:12:29 UTC 2023 - 5.1K bytes - Viewed (0) -
tensorflow/compiler/mlir/tfrt/runtime_fallback/runtime_fallback_executor.cc
#include "tensorflow/compiler/mlir/tfrt/transforms/passes.h" #include "tensorflow/compiler/mlir/tfrt/utils/host_context.h" #include "tensorflow/core/framework/tensor.h" #include "tensorflow/core/platform/threadpool.h" #include "tensorflow/core/platform/threadpool_interface.h" #include "tensorflow/core/runtime_fallback/kernel/kernel_fallback_execute_compat_eager.h" #include "tensorflow/core/runtime_fallback/runtime/kernel_utils.h"
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed May 08 00:18:59 UTC 2024 - 9.1K bytes - Viewed (0) -
tensorflow/compiler/aot/benchmark_main.template
// clang-format off #define CPP_CLASS {{TFCOMPILE_CPP_CLASS}} // NOLINT(whitespace/braces) // clang-format on namespace tensorflow { namespace tfcompile { int Main(int argc, char** argv) { Eigen::ThreadPool pool(1 /* num_threads */); Eigen::ThreadPoolDevice device(&pool, pool.NumThreads()); CPP_CLASS computation; computation.set_thread_pool(&device); benchmark::Options options; benchmark::Stats stats;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Oct 19 20:05:05 UTC 2023 - 1.6K bytes - Viewed (0)