OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 "base/atomic_sequence_num.h" | 5 #include "base/atomic_sequence_num.h" |
6 #include "base/strings/string_number_conversions.h" | 6 #include "base/strings/string_number_conversions.h" |
7 #include "base/synchronization/waitable_event.h" | 7 #include "base/synchronization/waitable_event.h" |
8 #include "base/threading/simple_thread.h" | 8 #include "base/threading/simple_thread.h" |
9 #include "testing/gtest/include/gtest/gtest.h" | 9 #include "testing/gtest/include/gtest/gtest.h" |
10 | 10 |
(...skipping 77 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
88 EXPECT_FALSE(thread.HasBeenJoined()); | 88 EXPECT_FALSE(thread.HasBeenJoined()); |
89 | 89 |
90 thread.Join(); | 90 thread.Join(); |
91 EXPECT_TRUE(thread.HasBeenStarted()); | 91 EXPECT_TRUE(thread.HasBeenStarted()); |
92 EXPECT_TRUE(thread.HasBeenJoined()); | 92 EXPECT_TRUE(thread.HasBeenJoined()); |
93 EXPECT_EQ(7, stack_int); | 93 EXPECT_EQ(7, stack_int); |
94 } | 94 } |
95 | 95 |
96 TEST(SimpleThreadTest, WaitForEvent) { | 96 TEST(SimpleThreadTest, WaitForEvent) { |
97 // Create a thread, and wait for it to signal us. | 97 // Create a thread, and wait for it to signal us. |
98 WaitableEvent event(true, false); | 98 WaitableEvent event(WaitableEvent::ResetPolicy::MANUAL, |
| 99 WaitableEvent::InitialState::NOT_SIGNALED); |
99 | 100 |
100 WaitEventRunner runner(&event); | 101 WaitEventRunner runner(&event); |
101 DelegateSimpleThread thread(&runner, "event_waiter"); | 102 DelegateSimpleThread thread(&runner, "event_waiter"); |
102 | 103 |
103 EXPECT_FALSE(event.IsSignaled()); | 104 EXPECT_FALSE(event.IsSignaled()); |
104 thread.Start(); | 105 thread.Start(); |
105 event.Wait(); | 106 event.Wait(); |
106 EXPECT_TRUE(event.IsSignaled()); | 107 EXPECT_TRUE(event.IsSignaled()); |
107 thread.Join(); | 108 thread.Join(); |
108 } | 109 } |
109 | 110 |
110 TEST(SimpleThreadTest, NamedWithOptions) { | 111 TEST(SimpleThreadTest, NamedWithOptions) { |
111 WaitableEvent event(true, false); | 112 WaitableEvent event(WaitableEvent::ResetPolicy::MANUAL, |
| 113 WaitableEvent::InitialState::NOT_SIGNALED); |
112 | 114 |
113 WaitEventRunner runner(&event); | 115 WaitEventRunner runner(&event); |
114 SimpleThread::Options options; | 116 SimpleThread::Options options; |
115 DelegateSimpleThread thread(&runner, "event_waiter", options); | 117 DelegateSimpleThread thread(&runner, "event_waiter", options); |
116 EXPECT_EQ(thread.name_prefix(), "event_waiter"); | 118 EXPECT_EQ(thread.name_prefix(), "event_waiter"); |
117 EXPECT_FALSE(event.IsSignaled()); | 119 EXPECT_FALSE(event.IsSignaled()); |
118 | 120 |
119 thread.Start(); | 121 thread.Start(); |
120 EXPECT_EQ(thread.name_prefix(), "event_waiter"); | 122 EXPECT_EQ(thread.name_prefix(), "event_waiter"); |
121 EXPECT_EQ(thread.name(), | 123 EXPECT_EQ(thread.name(), |
(...skipping 23 matching lines...) Expand all Loading... |
145 // Add work while we're running. | 147 // Add work while we're running. |
146 pool.AddWork(&runner, 300); | 148 pool.AddWork(&runner, 300); |
147 | 149 |
148 pool.JoinAll(); | 150 pool.JoinAll(); |
149 | 151 |
150 EXPECT_EQ(seq.GetNext(), 601); | 152 EXPECT_EQ(seq.GetNext(), 601); |
151 | 153 |
152 // We can reuse our pool. Verify that all 10 threads can actually run in | 154 // We can reuse our pool. Verify that all 10 threads can actually run in |
153 // parallel, so this test will only pass if there are actually 10 threads. | 155 // parallel, so this test will only pass if there are actually 10 threads. |
154 AtomicSequenceNumber seq2; | 156 AtomicSequenceNumber seq2; |
155 WaitableEvent event(true, false); | 157 WaitableEvent event(WaitableEvent::ResetPolicy::MANUAL, |
| 158 WaitableEvent::InitialState::NOT_SIGNALED); |
156 // Changing 9 to 10, for example, would cause us JoinAll() to never return. | 159 // Changing 9 to 10, for example, would cause us JoinAll() to never return. |
157 VerifyPoolRunner verifier(&seq2, 9, &event); | 160 VerifyPoolRunner verifier(&seq2, 9, &event); |
158 pool.Start(); | 161 pool.Start(); |
159 | 162 |
160 pool.AddWork(&verifier, 10); | 163 pool.AddWork(&verifier, 10); |
161 | 164 |
162 pool.JoinAll(); | 165 pool.JoinAll(); |
163 EXPECT_EQ(seq2.GetNext(), 10); | 166 EXPECT_EQ(seq2.GetNext(), 10); |
164 } | 167 } |
165 | 168 |
166 } // namespace base | 169 } // namespace base |
OLD | NEW |