Synchronize memory in TaskTracker::Flush().

base/task_scheduler/task_tracker.cc

 // Copyright 2016 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "base/task_scheduler/task_tracker.h"
 
 #include <limits>
 #include <string>
 
 #include "base/callback.h"
@@ skipping 197 matching lines @@
   PerformShutdown();
   DCHECK(IsShutdownComplete());
 
   // Unblock Flush() when shutdown completes.
   AutoSchedulerLock auto_lock(flush_lock_);
   flush_cv_->Signal();
 }
 
 void TaskTracker::Flush() {
   AutoSchedulerLock auto_lock(flush_lock_);
-  while (subtle::NoBarrier_Load(&num_pending_undelayed_tasks_) != 0 &&
+  while (subtle::Acquire_Load(&num_pending_undelayed_tasks_) != 0 &&
          !IsShutdownComplete()) {
     flush_cv_->Wait();
   }
 }
 
 bool TaskTracker::WillPostTask(const Task* task) {
   DCHECK(task);
 
   if (!BeforePostTask(task->traits.shutdown_behavior()))
     return false;
@@ skipping 248 matching lines @@
 
   // This method can only be called after shutdown has started.
   DCHECK(state_->HasShutdownStarted());
   DCHECK(shutdown_event_);
 
   shutdown_event_->Signal();
 }
 
 void TaskTracker::DecrementNumPendingUndelayedTasks() {
   const auto new_num_pending_undelayed_tasks =
-      subtle::NoBarrier_AtomicIncrement(&num_pending_undelayed_tasks_, -1);
+      subtle::Barrier_AtomicIncrement(&num_pending_undelayed_tasks_, -1);
   DCHECK_GE(new_num_pending_undelayed_tasks, 0);
   if (new_num_pending_undelayed_tasks == 0) {
     AutoSchedulerLock auto_lock(flush_lock_);
     flush_cv_->Signal();
   }
 }
 
 void TaskTracker::RecordTaskLatencyHistogram(Task* task) {
   const TimeDelta task_latency = TimeTicks::Now() - task->sequenced_time;
   task_latency_histograms_[static_cast<int>(task->traits.priority())]
                           [task->traits.may_block() ||
                                    task->traits.with_base_sync_primitives()
                                ? 1
                                : 0]
                               ->Add(task_latency.InMicroseconds());
 }
 
 }  // namespace internal
 }  // namespace base