- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 26 for thread (0.17 sec)
-
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache_test.cc
notification.Notify(); // Wait for other thread to issue read. Env::Default()->SleepForMicroseconds(100000); // 0.1 secs TF_SetStatus(status, TF_OK, ""); return n; }; tf_gcs_filesystem::RamFileBlockCache cache(block_size, block_size, 0, fetcher); // Fork off thread for parallel read. std::unique_ptr<Thread> concurrent(
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Fri Oct 15 03:16:57 GMT 2021 - 23.2K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache.cc
const std::shared_ptr<Block>& block, TF_Status* status) { absl::MutexLock lock(&mu_); if (block->timestamp == 0) { // The block was evicted from another thread. Allow it to remain evicted. return TF_SetStatus(status, TF_OK, ""); } if (block->lru_iterator != lru_list_.begin()) { lru_list_.erase(block->lru_iterator); lru_list_.push_front(key);
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Thu Jul 16 01:39:09 GMT 2020 - 11.1K bytes - Viewed (0) -
tensorflow/c/env.cc
cc_options.numa_node = options->numa_node; return reinterpret_cast<TF_Thread*>(::tensorflow::Env::Default()->StartThread( cc_options, thread_name, [=]() { (*work_func)(param); })); } void TF_JoinThread(TF_Thread* thread) { // ::tensorflow::Thread joins on destruction delete reinterpret_cast<::tensorflow::Thread*>(thread); } void* TF_LoadSharedLibrary(const char* library_filename, TF_Status* status) {
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Wed Aug 11 01:20:50 GMT 2021 - 7K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache.h
block_fetcher_(block_fetcher), timer_seconds_(timer_seconds), pruning_thread_(nullptr, [](TF_Thread* thread) { TF_JoinThread(thread); }) { if (max_staleness_ > 0) { TF_ThreadOptions thread_options; TF_DefaultThreadOptions(&thread_options); pruning_thread_.reset( TF_StartThread(&thread_options, "TF_prune_FBC", PruneThread, this)); }
C - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Mon Aug 31 04:46:34 GMT 2020 - 10.6K bytes - Viewed (0) -
tensorflow/c/env_test.cc
} } // namespace TEST(TestEnv, TestThreads) { TF_ThreadOptions options; TF_DefaultThreadOptions(&options); SomeThreadData data; TF_Thread* thread = TF_StartThread(&options, "SomeThreadName", &SomeThreadFunc, &data); TF_JoinThread(thread); ::tensorflow::mutex_lock l(data.mu); ASSERT_TRUE(data.did_work);
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Mon Dec 10 20:52:48 GMT 2018 - 4.2K bytes - Viewed (0) -
tensorflow/c/eager/immediate_execution_context.h
virtual void SetJitCompileRewrite(bool enable) = 0; // Sets the device placement policy for the current thread. virtual void SetThreadLocalDevicePlacementPolicy( ContextDevicePlacementPolicy policy) = 0; // Returns the device placement policy for the current thread. virtual ContextDevicePlacementPolicy GetDevicePlacementPolicy() const = 0; // Configure graph collection in RunMetadata.
C - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Jul 06 08:34:00 GMT 2023 - 12.3K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/expiring_lru_cache.h
#include <memory> #include <string> #include "absl/base/thread_annotations.h" #include "absl/synchronization/mutex.h" #include "tensorflow/c/env.h" #include "tensorflow/c/tf_status.h" namespace tf_gcs_filesystem { /// \brief An LRU cache of string keys and arbitrary values, with configurable /// max item age (in seconds) and max entries. /// /// This class is thread safe. template <typename T> class ExpiringLRUCache {
C - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Jul 09 19:31:22 GMT 2020 - 6.3K bytes - Viewed (0) -
tensorflow/c/eager/c_api.h
// ops. TF_CAPI_EXPORT extern void TFE_ContextClearCaches(TFE_Context* ctx); // Sets a thread-local device placement policy. After this call, other calls to // TFE_Execute in the same thread will use the device policy specified here // instead of the device policy used to construct the context. This has no // effect on the device policy used by other program threads. TF_CAPI_EXPORT extern void TFE_ContextSetThreadLocalDevicePlacementPolicy(
C - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Apr 27 21:07:00 GMT 2023 - 22.8K bytes - Viewed (1) -
tensorflow/c/eager/parallel_device/parallel_device_lib.cc
// unnecessary allocations each Execute call, we keep one heap-allocated // version for the thread. StatusPtr status_ TF_GUARDED_BY(execution_mutex_); const std::string device_; ExecutorPtr executor_ TF_GUARDED_BY(execution_mutex_); mutable OpPtr op_ TF_GUARDED_BY(execution_mutex_); std::unique_ptr<Thread> thread_; }; DeviceThread::~DeviceThread() { { tensorflow::mutex_lock l(execution_mutex_);
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Fri Feb 09 07:47:20 GMT 2024 - 25.4K bytes - Viewed (1) -
tensorflow/c/env.h
TF_CAPI_EXPORT extern TF_Thread* TF_StartThread(const TF_ThreadOptions* options, const char* thread_name, void (*work_func)(void*), void* param); // Waits for the given thread to finish execution, then deletes it. TF_CAPI_EXPORT extern void TF_JoinThread(TF_Thread* thread);
C - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Sat Jan 09 02:53:27 GMT 2021 - 9.6K bytes - Viewed (0)