diff --git a/internal/platform/task_runner_impl.cc b/internal/platform/task_runner_impl.cc index c418634b..a06e3d18 100644 --- a/internal/platform/task_runner_impl.cc +++ b/internal/platform/task_runner_impl.cc @@ -40,7 +40,7 @@ TaskRunnerImpl::TaskRunnerImpl(uint32_t runner_count) { TaskRunnerImpl::~TaskRunnerImpl() { { - absl::MutexLock lock(&mutex_); + absl::MutexLock lock(mutex_); if (closed_) { return; } @@ -51,7 +51,7 @@ TaskRunnerImpl::~TaskRunnerImpl() { void TaskRunnerImpl::Shutdown() { absl::flat_hash_map> timers; { - absl::MutexLock lock(&mutex_); + absl::MutexLock lock(mutex_); closed_ = true; timers = std::move(timers_map_); } @@ -65,7 +65,7 @@ void TaskRunnerImpl::Shutdown() { bool TaskRunnerImpl::PostTask(absl::AnyInvocable task) { { - absl::MutexLock lock(&mutex_); + absl::MutexLock lock(mutex_); if (closed_) { return false; } @@ -81,7 +81,7 @@ bool TaskRunnerImpl::PostTask(absl::AnyInvocable task) { bool TaskRunnerImpl::PostDelayedTask(absl::Duration delay, absl::AnyInvocable task) { - absl::MutexLock lock(&mutex_); + absl::MutexLock lock(mutex_); if (closed_) { return false; } @@ -94,10 +94,10 @@ bool TaskRunnerImpl::PostDelayedTask(absl::Duration delay, [this, id, task = std::move(task)]() mutable { std::unique_ptr timer; { - absl::MutexLock lock(&mutex_); - if (closed_) { - return; - } + absl::MutexLock lock(mutex_); + if (closed_) { + return; + } timer = std::move(timers_map_.extract(id).mapped()); } PostTask(std::move(task)); diff --git a/internal/platform/timer_impl.cc b/internal/platform/timer_impl.cc index 20aaf455..3140ed6f 100644 --- a/internal/platform/timer_impl.cc +++ b/internal/platform/timer_impl.cc @@ -31,7 +31,7 @@ bool TimerImpl::Start(int delay, int period, if (period < 0) { period = 0; } - absl::MutexLock lock(&mutex_); + absl::MutexLock lock(mutex_); if (internal_timer_ != nullptr) { LOG(INFO) << "The timer is already running."; return false; @@ -47,7 +47,7 @@ bool TimerImpl::Start(int delay, int period, } void TimerImpl::Stop() { - absl::MutexLock lock(&mutex_); + absl::MutexLock lock(mutex_); if (internal_timer_ == nullptr) { return; } @@ -57,7 +57,7 @@ void TimerImpl::Stop() { } bool TimerImpl::IsRunning() { - absl::MutexLock lock(&mutex_); + absl::MutexLock lock(mutex_); return (internal_timer_ != nullptr); }