- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for thread_pool_ (0.25 sec)
-
tensorflow/cc/training/queue_runner.cc
Status QueueRunner::Start(Session* sess, int wait_for) { counter_.reset(new BlockingCounter(runs_)); for (const string& enqueue_op : enqueue_op_names_) { thread_pool_->Schedule( std::bind(&QueueRunner::Run, this, sess, enqueue_op)); } if (coord_) { thread_pool_->Schedule(std::bind(&QueueRunner::Stop, this, sess)); } // Wait for up to 'wait_for' milliseconds. if (wait_for > 0) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Apr 13 08:30:37 UTC 2024 - 7K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_device_context.h
xla::TransferManager* transfer_manager_; XlaShapeLayoutHelpers::ShapeDeterminationFns shape_determination_fns_; // Thread pool used for running closures thread::ThreadPool* thread_pool_; absl::Mutex mu_; int next_stream_ TF_GUARDED_BY(mu_) = 0; }; } // namespace tensorflow
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/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) -
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) -
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) -
.github/workflows/CheckBadMerge.groovy
* Usage: groovy CheckBadMerge.groovy <commit1> <commit2> ... * If any "bad" merge commit is found, it will print the details and exit with non-zero code. */ class CheckBadMerge { private static final THREAD_POOL = Executors.newCachedThreadPool() private static final List<String> MONITORED_FILES = [ "subprojects/docs/src/docs/release/notes.md", "platforms/documentation/docs/src/docs/release/notes.md",
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Dec 19 10:35:44 UTC 2023 - 6.5K 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 (0) -
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)