123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266 |
- // Copyright (c) 2012 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/synchronization/waitable_event.h"
- #include <stddef.h>
- #include <algorithm>
- #include "base/compiler_specific.h"
- #include "base/memory/raw_ptr.h"
- #include "base/threading/platform_thread.h"
- #include "base/time/time.h"
- #include "build/build_config.h"
- #include "testing/gtest/include/gtest/gtest.h"
- namespace base {
- TEST(WaitableEventTest, ManualBasics) {
- WaitableEvent event(WaitableEvent::ResetPolicy::MANUAL,
- WaitableEvent::InitialState::NOT_SIGNALED);
- EXPECT_FALSE(event.IsSignaled());
- event.Signal();
- EXPECT_TRUE(event.IsSignaled());
- EXPECT_TRUE(event.IsSignaled());
- event.Reset();
- EXPECT_FALSE(event.IsSignaled());
- EXPECT_FALSE(event.TimedWait(Milliseconds(10)));
- event.Signal();
- event.Wait();
- EXPECT_TRUE(event.TimedWait(Milliseconds(10)));
- }
- TEST(WaitableEventTest, ManualInitiallySignaled) {
- WaitableEvent event(WaitableEvent::ResetPolicy::MANUAL,
- WaitableEvent::InitialState::SIGNALED);
- EXPECT_TRUE(event.IsSignaled());
- EXPECT_TRUE(event.IsSignaled());
- event.Reset();
- EXPECT_FALSE(event.IsSignaled());
- EXPECT_FALSE(event.IsSignaled());
- event.Signal();
- event.Wait();
- EXPECT_TRUE(event.IsSignaled());
- EXPECT_TRUE(event.IsSignaled());
- }
- TEST(WaitableEventTest, AutoBasics) {
- WaitableEvent event(WaitableEvent::ResetPolicy::AUTOMATIC,
- WaitableEvent::InitialState::NOT_SIGNALED);
- EXPECT_FALSE(event.IsSignaled());
- event.Signal();
- EXPECT_TRUE(event.IsSignaled());
- EXPECT_FALSE(event.IsSignaled());
- event.Reset();
- EXPECT_FALSE(event.IsSignaled());
- EXPECT_FALSE(event.TimedWait(Milliseconds(10)));
- event.Signal();
- event.Wait();
- EXPECT_FALSE(event.TimedWait(Milliseconds(10)));
- event.Signal();
- EXPECT_TRUE(event.TimedWait(Milliseconds(10)));
- }
- TEST(WaitableEventTest, AutoInitiallySignaled) {
- WaitableEvent event(WaitableEvent::ResetPolicy::AUTOMATIC,
- WaitableEvent::InitialState::SIGNALED);
- EXPECT_TRUE(event.IsSignaled());
- EXPECT_FALSE(event.IsSignaled());
- event.Signal();
- EXPECT_TRUE(event.IsSignaled());
- EXPECT_FALSE(event.IsSignaled());
- }
- TEST(WaitableEventTest, WaitManyShortcut) {
- WaitableEvent* ev[5];
- for (auto*& i : ev) {
- i = new WaitableEvent(WaitableEvent::ResetPolicy::AUTOMATIC,
- WaitableEvent::InitialState::NOT_SIGNALED);
- }
- ev[3]->Signal();
- EXPECT_EQ(WaitableEvent::WaitMany(ev, 5), 3u);
- ev[3]->Signal();
- EXPECT_EQ(WaitableEvent::WaitMany(ev, 5), 3u);
- ev[4]->Signal();
- EXPECT_EQ(WaitableEvent::WaitMany(ev, 5), 4u);
- ev[0]->Signal();
- EXPECT_EQ(WaitableEvent::WaitMany(ev, 5), 0u);
- for (auto* i : ev)
- delete i;
- }
- TEST(WaitableEventTest, WaitManyLeftToRight) {
- WaitableEvent* ev[5];
- for (auto*& i : ev) {
- i = new WaitableEvent(WaitableEvent::ResetPolicy::AUTOMATIC,
- WaitableEvent::InitialState::NOT_SIGNALED);
- }
- // Test for consistent left-to-right return behavior across all permutations
- // of the input array. This is to verify that only the indices -- and not
- // the WaitableEvents' addresses -- are relevant in determining who wins when
- // multiple events are signaled.
- std::sort(ev, ev + 5);
- do {
- ev[0]->Signal();
- ev[1]->Signal();
- EXPECT_EQ(0u, WaitableEvent::WaitMany(ev, 5));
- ev[2]->Signal();
- EXPECT_EQ(1u, WaitableEvent::WaitMany(ev, 5));
- EXPECT_EQ(2u, WaitableEvent::WaitMany(ev, 5));
- ev[3]->Signal();
- ev[4]->Signal();
- ev[0]->Signal();
- EXPECT_EQ(0u, WaitableEvent::WaitMany(ev, 5));
- EXPECT_EQ(3u, WaitableEvent::WaitMany(ev, 5));
- ev[2]->Signal();
- EXPECT_EQ(2u, WaitableEvent::WaitMany(ev, 5));
- EXPECT_EQ(4u, WaitableEvent::WaitMany(ev, 5));
- } while (std::next_permutation(ev, ev + 5));
- for (auto* i : ev)
- delete i;
- }
- class WaitableEventSignaler : public PlatformThread::Delegate {
- public:
- WaitableEventSignaler(TimeDelta delay, WaitableEvent* event)
- : delay_(delay),
- event_(event) {
- }
- void ThreadMain() override {
- PlatformThread::Sleep(delay_);
- event_->Signal();
- }
- private:
- const TimeDelta delay_;
- raw_ptr<WaitableEvent> event_;
- };
- // Tests that a WaitableEvent can be safely deleted when |Wait| is done without
- // additional synchronization.
- TEST(WaitableEventTest, WaitAndDelete) {
- WaitableEvent* ev =
- new WaitableEvent(WaitableEvent::ResetPolicy::AUTOMATIC,
- WaitableEvent::InitialState::NOT_SIGNALED);
- WaitableEventSignaler signaler(Milliseconds(10), ev);
- PlatformThreadHandle thread;
- PlatformThread::Create(0, &signaler, &thread);
- ev->Wait();
- delete ev;
- PlatformThread::Join(thread);
- }
- // Tests that a WaitableEvent can be safely deleted when |WaitMany| is done
- // without additional synchronization.
- TEST(WaitableEventTest, WaitMany) {
- WaitableEvent* ev[5];
- for (auto*& i : ev) {
- i = new WaitableEvent(WaitableEvent::ResetPolicy::AUTOMATIC,
- WaitableEvent::InitialState::NOT_SIGNALED);
- }
- WaitableEventSignaler signaler(Milliseconds(10), ev[2]);
- PlatformThreadHandle thread;
- PlatformThread::Create(0, &signaler, &thread);
- size_t index = WaitableEvent::WaitMany(ev, 5);
- for (auto* i : ev)
- delete i;
- PlatformThread::Join(thread);
- EXPECT_EQ(2u, index);
- }
- // Tests that using TimeDelta::Max() on TimedWait() is not the same as passing
- // a timeout of 0. (crbug.com/465948)
- TEST(WaitableEventTest, TimedWait) {
- WaitableEvent* ev =
- new WaitableEvent(WaitableEvent::ResetPolicy::AUTOMATIC,
- WaitableEvent::InitialState::NOT_SIGNALED);
- TimeDelta thread_delay = Milliseconds(10);
- WaitableEventSignaler signaler(thread_delay, ev);
- PlatformThreadHandle thread;
- TimeTicks start = TimeTicks::Now();
- PlatformThread::Create(0, &signaler, &thread);
- EXPECT_TRUE(ev->TimedWait(TimeDelta::Max()));
- EXPECT_GE(TimeTicks::Now() - start, thread_delay);
- delete ev;
- PlatformThread::Join(thread);
- }
- // Tests that a sub-ms TimedWait doesn't time out promptly.
- TEST(WaitableEventTest, SubMsTimedWait) {
- WaitableEvent ev(WaitableEvent::ResetPolicy::AUTOMATIC,
- WaitableEvent::InitialState::NOT_SIGNALED);
- TimeDelta delay = Microseconds(900);
- TimeTicks start_time = TimeTicks::Now();
- ev.TimedWait(delay);
- EXPECT_GE(TimeTicks::Now() - start_time, delay);
- }
- // Tests that timeouts of zero return immediately (true if already signaled,
- // false otherwise).
- TEST(WaitableEventTest, ZeroTimeout) {
- WaitableEvent ev;
- TimeTicks start_time = TimeTicks::Now();
- EXPECT_FALSE(ev.TimedWait(TimeDelta()));
- EXPECT_LT(TimeTicks::Now() - start_time, Milliseconds(1));
- ev.Signal();
- start_time = TimeTicks::Now();
- EXPECT_TRUE(ev.TimedWait(TimeDelta()));
- EXPECT_LT(TimeTicks::Now() - start_time, Milliseconds(1));
- }
- // Same as ZeroTimeout for negative timeouts.
- TEST(WaitableEventTest, NegativeTimeout) {
- WaitableEvent ev;
- TimeTicks start_time = TimeTicks::Now();
- EXPECT_FALSE(ev.TimedWait(Milliseconds(-10)));
- EXPECT_LT(TimeTicks::Now() - start_time, Milliseconds(1));
- ev.Signal();
- start_time = TimeTicks::Now();
- EXPECT_TRUE(ev.TimedWait(Milliseconds(-10)));
- EXPECT_LT(TimeTicks::Now() - start_time, Milliseconds(1));
- }
- } // namespace base
|