| OLD | NEW |
| 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include <stdlib.h> | 5 #include <stdlib.h> |
| 6 | 6 |
| 7 #include "base/synchronization/lock.h" | 7 #include "base/synchronization/lock.h" |
| 8 #include "base/threading/platform_thread.h" | 8 #include "base/threading/platform_thread.h" |
| 9 #include "testing/gtest/include/gtest/gtest.h" | 9 #include "testing/gtest/include/gtest/gtest.h" |
| 10 | 10 |
| 11 namespace base { | 11 namespace base { |
| 12 | 12 |
| 13 // Basic test to make sure that Acquire()/Release()/Try() don't crash ---------- | 13 // Basic test to make sure that Acquire()/Release()/Try() don't crash ---------- |
| 14 | 14 |
| 15 class BasicLockTestThread : public PlatformThread::Delegate { | 15 class BasicLockTestThread : public PlatformThread::Delegate { |
| 16 public: | 16 public: |
| 17 BasicLockTestThread(Lock* lock) : lock_(lock), acquired_(0) {} | 17 BasicLockTestThread(Lock* lock) : lock_(lock), acquired_(0) {} |
| 18 | 18 |
| 19 virtual void ThreadMain() { | 19 virtual void ThreadMain() { |
| 20 for (int i = 0; i < 10; i++) { | 20 for (int i = 0; i < 10; i++) { |
| 21 lock_->Acquire(); | 21 lock_->Acquire(); |
| 22 acquired_++; | 22 acquired_++; |
| 23 lock_->Release(); | 23 lock_->Release(); |
| 24 } | 24 } |
| 25 for (int i = 0; i < 10; i++) { | 25 for (int i = 0; i < 10; i++) { |
| 26 lock_->Acquire(); | 26 lock_->Acquire(); |
| 27 acquired_++; | 27 acquired_++; |
| 28 PlatformThread::Sleep(rand() % 20); | 28 PlatformThread::Sleep(TimeDelta::FromMilliseconds(rand() % 20)); |
| 29 lock_->Release(); | 29 lock_->Release(); |
| 30 } | 30 } |
| 31 for (int i = 0; i < 10; i++) { | 31 for (int i = 0; i < 10; i++) { |
| 32 if (lock_->Try()) { | 32 if (lock_->Try()) { |
| 33 acquired_++; | 33 acquired_++; |
| 34 PlatformThread::Sleep(rand() % 20); | 34 PlatformThread::Sleep(TimeDelta::FromMilliseconds(rand() % 20)); |
| 35 lock_->Release(); | 35 lock_->Release(); |
| 36 } | 36 } |
| 37 } | 37 } |
| 38 } | 38 } |
| 39 | 39 |
| 40 int acquired() const { return acquired_; } | 40 int acquired() const { return acquired_; } |
| 41 | 41 |
| 42 private: | 42 private: |
| 43 Lock* lock_; | 43 Lock* lock_; |
| 44 int acquired_; | 44 int acquired_; |
| (...skipping 10 matching lines...) Expand all Loading... |
| 55 | 55 |
| 56 int acquired = 0; | 56 int acquired = 0; |
| 57 for (int i = 0; i < 5; i++) { | 57 for (int i = 0; i < 5; i++) { |
| 58 lock.Acquire(); | 58 lock.Acquire(); |
| 59 acquired++; | 59 acquired++; |
| 60 lock.Release(); | 60 lock.Release(); |
| 61 } | 61 } |
| 62 for (int i = 0; i < 10; i++) { | 62 for (int i = 0; i < 10; i++) { |
| 63 lock.Acquire(); | 63 lock.Acquire(); |
| 64 acquired++; | 64 acquired++; |
| 65 PlatformThread::Sleep(rand() % 20); | 65 PlatformThread::Sleep(TimeDelta::FromMilliseconds(rand() % 20)); |
| 66 lock.Release(); | 66 lock.Release(); |
| 67 } | 67 } |
| 68 for (int i = 0; i < 10; i++) { | 68 for (int i = 0; i < 10; i++) { |
| 69 if (lock.Try()) { | 69 if (lock.Try()) { |
| 70 acquired++; | 70 acquired++; |
| 71 PlatformThread::Sleep(rand() % 20); | 71 PlatformThread::Sleep(TimeDelta::FromMilliseconds(rand() % 20)); |
| 72 lock.Release(); | 72 lock.Release(); |
| 73 } | 73 } |
| 74 } | 74 } |
| 75 for (int i = 0; i < 5; i++) { | 75 for (int i = 0; i < 5; i++) { |
| 76 lock.Acquire(); | 76 lock.Acquire(); |
| 77 acquired++; | 77 acquired++; |
| 78 PlatformThread::Sleep(rand() % 20); | 78 PlatformThread::Sleep(TimeDelta::FromMilliseconds(rand() % 20)); |
| 79 lock.Release(); | 79 lock.Release(); |
| 80 } | 80 } |
| 81 | 81 |
| 82 PlatformThread::Join(handle); | 82 PlatformThread::Join(handle); |
| 83 | 83 |
| 84 EXPECT_GE(acquired, 20); | 84 EXPECT_GE(acquired, 20); |
| 85 EXPECT_GE(thread.acquired(), 20); | 85 EXPECT_GE(thread.acquired(), 20); |
| 86 } | 86 } |
| 87 | 87 |
| 88 // Test that Try() works as expected ------------------------------------------- | 88 // Test that Try() works as expected ------------------------------------------- |
| (...skipping 58 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 147 | 147 |
| 148 class MutexLockTestThread : public PlatformThread::Delegate { | 148 class MutexLockTestThread : public PlatformThread::Delegate { |
| 149 public: | 149 public: |
| 150 MutexLockTestThread(Lock* lock, int* value) : lock_(lock), value_(value) {} | 150 MutexLockTestThread(Lock* lock, int* value) : lock_(lock), value_(value) {} |
| 151 | 151 |
| 152 // Static helper which can also be called from the main thread. | 152 // Static helper which can also be called from the main thread. |
| 153 static void DoStuff(Lock* lock, int* value) { | 153 static void DoStuff(Lock* lock, int* value) { |
| 154 for (int i = 0; i < 40; i++) { | 154 for (int i = 0; i < 40; i++) { |
| 155 lock->Acquire(); | 155 lock->Acquire(); |
| 156 int v = *value; | 156 int v = *value; |
| 157 PlatformThread::Sleep(rand() % 10); | 157 PlatformThread::Sleep(TimeDelta::FromMilliseconds(rand() % 10)); |
| 158 *value = v + 1; | 158 *value = v + 1; |
| 159 lock->Release(); | 159 lock->Release(); |
| 160 } | 160 } |
| 161 } | 161 } |
| 162 | 162 |
| 163 virtual void ThreadMain() { | 163 virtual void ThreadMain() { |
| 164 DoStuff(lock_, value_); | 164 DoStuff(lock_, value_); |
| 165 } | 165 } |
| 166 | 166 |
| 167 private: | 167 private: |
| (...skipping 37 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 205 MutexLockTestThread::DoStuff(&lock, &value); | 205 MutexLockTestThread::DoStuff(&lock, &value); |
| 206 | 206 |
| 207 PlatformThread::Join(handle1); | 207 PlatformThread::Join(handle1); |
| 208 PlatformThread::Join(handle2); | 208 PlatformThread::Join(handle2); |
| 209 PlatformThread::Join(handle3); | 209 PlatformThread::Join(handle3); |
| 210 | 210 |
| 211 EXPECT_EQ(4 * 40, value); | 211 EXPECT_EQ(4 * 40, value); |
| 212 } | 212 } |
| 213 | 213 |
| 214 } // namespace base | 214 } // namespace base |
| OLD | NEW |