123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105 |
- // Copyright 2020 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/compiler_specific.h"
- #include "base/memory/raw_ptr.h"
- #include "base/synchronization/lock.h"
- #include "base/threading/platform_thread.h"
- #include "base/time/time.h"
- #include "base/timer/lap_timer.h"
- #include "testing/gtest/include/gtest/gtest.h"
- #include "testing/perf/perf_result_reporter.h"
- namespace base {
- namespace {
- constexpr int kWarmupRuns = 1;
- constexpr TimeDelta kTimeLimit = Seconds(1);
- constexpr int kTimeCheckInterval = 100000;
- constexpr char kMetricPrefixLock[] = "Lock.";
- constexpr char kMetricLockUnlockThroughput[] = "lock_unlock_throughput";
- constexpr char kStoryBaseline[] = "baseline_story";
- constexpr char kStoryWithCompetingThread[] = "with_competing_thread";
- perf_test::PerfResultReporter SetUpReporter(const std::string& story_name) {
- perf_test::PerfResultReporter reporter(kMetricPrefixLock, story_name);
- reporter.RegisterImportantMetric(kMetricLockUnlockThroughput, "runs/s");
- return reporter;
- }
- class Spin : public PlatformThread::Delegate {
- public:
- Spin(Lock* lock, uint32_t* data)
- : lock_(lock), data_(data), should_stop_(false) {}
- ~Spin() override = default;
- void ThreadMain() override {
- // Local variable to avoid "cache line ping-pong" from influencing the
- // results.
- uint32_t count = 0;
- while (!should_stop_.load(std::memory_order_relaxed)) {
- lock_->Acquire();
- count++;
- lock_->Release();
- }
- lock_->Acquire();
- (*data_) += count;
- lock_->Release();
- }
- // Called from another thread to stop the loop.
- void Stop() { should_stop_ = true; }
- private:
- raw_ptr<Lock> lock_;
- raw_ptr<uint32_t> data_ GUARDED_BY(lock_);
- std::atomic<bool> should_stop_;
- };
- } // namespace
- TEST(LockPerfTest, Simple) {
- LapTimer timer(kWarmupRuns, kTimeLimit, kTimeCheckInterval);
- [[maybe_unused]] uint32_t data = 0;
- Lock lock;
- do {
- lock.Acquire();
- data += 1;
- lock.Release();
- timer.NextLap();
- } while (!timer.HasTimeLimitExpired());
- auto reporter = SetUpReporter(kStoryBaseline);
- reporter.AddResult(kMetricLockUnlockThroughput, timer.LapsPerSecond());
- }
- TEST(LockPerfTest, WithCompetingThread) {
- LapTimer timer(kWarmupRuns, kTimeLimit, kTimeCheckInterval);
- uint32_t data = 0;
- Lock lock;
- // Starts a competing thread executing the same loop as this thread.
- Spin thread_main(&lock, &data);
- PlatformThreadHandle thread_handle;
- ASSERT_TRUE(PlatformThread::Create(0, &thread_main, &thread_handle));
- do {
- lock.Acquire();
- data += 1;
- lock.Release();
- timer.NextLap();
- } while (!timer.HasTimeLimitExpired());
- thread_main.Stop();
- PlatformThread::Join(thread_handle);
- auto reporter = SetUpReporter(kStoryWithCompetingThread);
- reporter.AddResult(kMetricLockUnlockThroughput, timer.LapsPerSecond());
- }
- } // namespace base
|