- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 52 for threadPool (0.13 sec)
-
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/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) -
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) -
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) -
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) -
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/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) -
tensorflow/cc/training/queue_runner.h
#include <memory> #include <string> #include <unordered_set> #include <vector> #include "tensorflow/cc/training/coordinator.h" #include "tensorflow/core/lib/core/status.h" #include "tensorflow/core/lib/core/threadpool.h" #include "tensorflow/core/platform/blocking_counter.h" #include "tensorflow/core/platform/mutex.h" #include "tensorflow/core/protobuf/config.pb.h" #include "tensorflow/core/protobuf/error_codes.pb.h"
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Aug 31 18:27:00 UTC 2022 - 5K bytes - Viewed (0) -
tensorflow/cc/training/coordinator_test.cc
} class MockQueueRunner : public RunnerInterface { public: explicit MockQueueRunner(Coordinator* coord) { coord_ = coord; join_counter_ = nullptr; thread_pool_.reset(new thread::ThreadPool(Env::Default(), "test-pool", 10)); stopped_ = false; } MockQueueRunner(Coordinator* coord, int* join_counter) : MockQueueRunner(coord) { join_counter_ = join_counter; }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Mar 23 09:10:43 UTC 2023 - 6.9K bytes - Viewed (0)