- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for mutex_lock (0.29 sec)
-
tensorflow/cc/training/coordinator.cc
{ mutex_lock l(mu_); if (should_stop_) { return Status(absl::StatusCode::kFailedPrecondition, "The coordinator has been stopped."); } } mutex_lock l(runners_lock_); runners_.push_back(std::move(runner)); return absl::OkStatus(); } bool Coordinator::AllRunnersStopped() { mutex_lock l(runners_lock_); for (const auto& runner : runners_) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Apr 13 08:30:37 UTC 2024 - 3.2K bytes - Viewed (0) -
tensorflow/cc/training/queue_runner.cc
Status QueueRunner::Join() { thread_pool_.reset(); mutex_lock l(mu_); return status_; } void QueueRunner::UpdateStatus(const Status& status) { { mutex_lock l(mu_); if (!status_.ok() || status.ok() || IsQueueClosed(status)) { return; } status_ = status; } if (coord_) { coord_->ReportStatus(status); } mutex_lock l(cb_mu_); for (auto& cb : callbacks_) {
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/device_compilation_profiler.cc
} void DeviceCompilationProfiler::IncrementOngoingAsyncCompilations() { mutex_lock lock(mu_); num_ongoing_compilations_++; } void DeviceCompilationProfiler::DecrementOngoingAsyncCompilations() { mutex_lock lock(mu_); num_ongoing_compilations_--; } int64_t DeviceCompilationProfiler::GetNumOngoingAsyncCompilations() const { mutex_lock lock(mu_); return num_ongoing_compilations_; }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 22 06:59:07 UTC 2024 - 8.5K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_tensor.cc
} void XlaTensor::ResetDefinitionEvent(std::shared_ptr<se::Event> event, se::Stream* stream) { mutex_lock lock(mu_); definition_event_ = std::move(event); streams_defined_on_ = {stream}; } Status XlaTensor::RefreshStatusOfStreams() { mutex_lock lock(mu_); Status status; for (se::Stream* stream : streams_defined_on_) { status.Update(stream->RefreshStatus()); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 22 08:47:20 UTC 2024 - 4.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/lift_variables.cc
#include "tensorflow/core/public/session.h" namespace mlir { namespace tf_saved_model { using llvm::SmallSet; using ::tensorflow::Device; using ::tensorflow::DeviceMgr; using ::tensorflow::mutex_lock; using ::tensorflow::ResourceHandle; using ::tensorflow::Session; using ::tensorflow::Status; using ::tensorflow::StatusOr; using ::tensorflow::Tensor; using ::tensorflow::Var; namespace {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu May 23 09:05:47 UTC 2024 - 7.9K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_device_ops.cc
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 22 08:47:20 UTC 2024 - 3K bytes - Viewed (0) -
tensorflow/cc/client/client_session.cc
std::vector<Tensor>* outputs) const { return Run(RunOptions(), inputs, fetch_outputs, run_outputs, outputs, nullptr); } Status ClientSession::Impl::MaybeExtendGraph() const { mutex_lock l(mu_); int num_nodes = graph_->num_node_ids(); if (num_nodes > last_num_graph_nodes_) { GraphDef graph_def; graph_->ToGraphDefSubRange(&graph_def, last_num_graph_nodes_); last_num_graph_nodes_ = num_nodes;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Feb 28 09:04:10 UTC 2024 - 7.1K bytes - Viewed (0) -
src/runtime/lock_futex.go
// futexwakeup(addr *uint32, cnt uint32) // If any procs are sleeping on addr, wake up at most cnt. const ( mutex_unlocked = 0 mutex_locked = 1 mutex_sleeping = 2 active_spin = 4 active_spin_cnt = 30 passive_spin = 1 ) // Possible lock states are mutex_unlocked, mutex_locked and mutex_sleeping. // mutex_sleeping means that there is presumably at least one sleeping thread.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:34 UTC 2024 - 5.4K bytes - Viewed (0) -
testing/performance/src/templates/native-dependents-resources/googleTest/libs/googleTest/1.7.0/include/gtest/internal/gtest-linked_ptr.h
// contention in production code, but is acceptable in a testing // framework. // Join an existing circle. void join(linked_ptr_internal const* ptr) GTEST_LOCK_EXCLUDED_(g_linked_ptr_mutex) { MutexLock lock(&g_linked_ptr_mutex); linked_ptr_internal const* p = ptr; while (p->next_ != ptr) p = p->next_; p->next_ = this; next_ = ptr; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 7.9K bytes - Viewed (0)