OLD | NEW |
1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 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/sequenced_task_runner.h" | 5 #include "base/sequenced_task_runner.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/gtest_prod_util.h" |
8 #include "base/message_loop/message_loop.h" | 9 #include "base/message_loop/message_loop.h" |
9 #include "base/run_loop.h" | 10 #include "base/run_loop.h" |
10 #include "base/threading/thread.h" | 11 #include "base/threading/thread.h" |
11 #include "testing/gtest/include/gtest/gtest.h" | 12 #include "testing/gtest/include/gtest/gtest.h" |
12 | 13 |
13 namespace base { | 14 namespace base { |
14 namespace { | 15 namespace { |
15 | 16 |
16 struct DeleteCounter { | 17 class FlagOnDelete { |
17 DeleteCounter(int* counter, scoped_refptr<SequencedTaskRunner> task_runner) | 18 public: |
18 : counter_(counter), | 19 FlagOnDelete(bool* deleted, |
19 task_runner_(std::move(task_runner)) { | 20 scoped_refptr<SequencedTaskRunner> expected_deletion_sequence) |
20 } | 21 : deleted_(deleted), |
21 ~DeleteCounter() { | 22 expected_deletion_sequence_(std::move(expected_deletion_sequence)) {} |
22 ++*counter_; | 23 |
23 EXPECT_TRUE(!task_runner_ || task_runner_->RunsTasksOnCurrentThread()); | 24 private: |
| 25 friend class DeleteHelper<FlagOnDelete>; |
| 26 FRIEND_TEST_ALL_PREFIXES(SequencedTaskRunnerTest, |
| 27 OnTaskRunnerDeleterTargetStoppedEarly); |
| 28 |
| 29 ~FlagOnDelete() { |
| 30 EXPECT_FALSE(*deleted_); |
| 31 *deleted_ = true; |
| 32 if (expected_deletion_sequence_) |
| 33 EXPECT_TRUE(expected_deletion_sequence_->RunsTasksInCurrentSequence()); |
24 } | 34 } |
25 | 35 |
26 int* counter_; | 36 bool* deleted_; |
27 scoped_refptr<SequencedTaskRunner> task_runner_; | 37 const scoped_refptr<SequencedTaskRunner> expected_deletion_sequence_; |
| 38 |
| 39 DISALLOW_COPY_AND_ASSIGN(FlagOnDelete); |
28 }; | 40 }; |
29 | 41 |
30 } // namespace | 42 class SequencedTaskRunnerTest : public testing::Test { |
| 43 protected: |
| 44 SequencedTaskRunnerTest() : foreign_thread_("foreign") {} |
31 | 45 |
32 TEST(SequencedTaskRunnerTest, OnTaskRunnerDeleter) { | 46 void SetUp() override { |
33 base::MessageLoop message_loop; | 47 main_runner_ = message_loop_.task_runner(); |
34 base::Thread thread("Foreign"); | |
35 thread.Start(); | |
36 | 48 |
37 scoped_refptr<SequencedTaskRunner> current_thread = | 49 foreign_thread_.Start(); |
38 message_loop.task_runner(); | 50 foreign_runner_ = foreign_thread_.task_runner(); |
39 scoped_refptr<SequencedTaskRunner> foreign_thread = | 51 } |
40 thread.task_runner(); | |
41 | 52 |
42 using SequenceBoundUniquePtr = | 53 scoped_refptr<SequencedTaskRunner> main_runner_; |
43 std::unique_ptr<DeleteCounter, OnTaskRunnerDeleter>; | 54 scoped_refptr<SequencedTaskRunner> foreign_runner_; |
44 | 55 |
45 int counter = 0; | 56 Thread foreign_thread_; |
46 SequenceBoundUniquePtr ptr(new DeleteCounter(&counter, current_thread), | 57 |
47 OnTaskRunnerDeleter(current_thread)); | 58 private: |
48 EXPECT_EQ(0, counter); | 59 MessageLoop message_loop_; |
49 foreign_thread->PostTask( | 60 |
| 61 DISALLOW_COPY_AND_ASSIGN(SequencedTaskRunnerTest); |
| 62 }; |
| 63 |
| 64 using SequenceBoundUniquePtr = |
| 65 std::unique_ptr<FlagOnDelete, OnTaskRunnerDeleter>; |
| 66 |
| 67 TEST_F(SequencedTaskRunnerTest, OnTaskRunnerDeleterOnMainThread) { |
| 68 bool deleted_on_main_thread = false; |
| 69 SequenceBoundUniquePtr ptr( |
| 70 new FlagOnDelete(&deleted_on_main_thread, main_runner_), |
| 71 OnTaskRunnerDeleter(main_runner_)); |
| 72 EXPECT_FALSE(deleted_on_main_thread); |
| 73 foreign_runner_->PostTask( |
50 FROM_HERE, BindOnce([](SequenceBoundUniquePtr) {}, Passed(&ptr))); | 74 FROM_HERE, BindOnce([](SequenceBoundUniquePtr) {}, Passed(&ptr))); |
51 | 75 |
52 { | 76 { |
53 RunLoop run_loop; | 77 RunLoop run_loop; |
54 foreign_thread->PostTaskAndReply(FROM_HERE, BindOnce([] {}), | 78 foreign_runner_->PostTaskAndReply(FROM_HERE, BindOnce([] {}), |
55 run_loop.QuitClosure()); | 79 run_loop.QuitClosure()); |
56 run_loop.Run(); | 80 run_loop.Run(); |
57 } | 81 } |
58 EXPECT_EQ(1, counter); | 82 EXPECT_TRUE(deleted_on_main_thread); |
| 83 } |
59 | 84 |
60 DeleteCounter* raw = new DeleteCounter(&counter, nullptr); | 85 TEST_F(SequencedTaskRunnerTest, OnTaskRunnerDeleterTargetStoppedEarly) { |
61 SequenceBoundUniquePtr ptr2(raw, OnTaskRunnerDeleter(foreign_thread)); | 86 bool deleted_on_main_thread = false; |
62 EXPECT_EQ(1, counter); | 87 FlagOnDelete* raw = new FlagOnDelete(&deleted_on_main_thread, main_runner_); |
| 88 SequenceBoundUniquePtr ptr(raw, OnTaskRunnerDeleter(foreign_runner_)); |
| 89 EXPECT_FALSE(deleted_on_main_thread); |
63 | 90 |
64 thread.Stop(); | 91 // Stopping the target ahead of deleting |ptr| should make its |
65 ptr2 = nullptr; | 92 // OnTaskRunnerDeleter no-op. |
66 ASSERT_EQ(1, counter); | 93 foreign_thread_.Stop(); |
| 94 ptr = nullptr; |
| 95 EXPECT_FALSE(deleted_on_main_thread); |
67 | 96 |
68 delete raw; | 97 delete raw; |
69 EXPECT_EQ(2, counter); | 98 EXPECT_TRUE(deleted_on_main_thread); |
70 } | 99 } |
71 | 100 |
| 101 } // namespace |
72 } // namespace base | 102 } // namespace base |
OLD | NEW |