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
3 // found in the LICENSE file.
5 #include "base/task_runner_util.h"
10 #include "base/location.h"
11 #include "base/run_loop.h"
12 #include "base/test/task_environment.h"
13 #include "base/threading/thread_task_runner_handle.h"
14 #include "testing/gtest/include/gtest/gtest.h"
20 int ReturnFourtyTwo() {
24 void StoreValue(int* destination, int value) {
28 void StoreDoubleValue(double* destination, double value) {
32 int g_foo_destruct_count = 0;
33 int g_foo_free_count = 0;
36 ~Foo() { ++g_foo_destruct_count; }
39 std::unique_ptr<Foo> CreateFoo() {
40 return std::unique_ptr<Foo>(new Foo);
43 void ExpectFoo(std::unique_ptr<Foo> foo) {
44 EXPECT_TRUE(foo.get());
45 std::unique_ptr<Foo> local_foo(std::move(foo));
46 EXPECT_TRUE(local_foo.get());
47 EXPECT_FALSE(foo.get());
51 void operator()(Foo* foo) const {
57 std::unique_ptr<Foo, FooDeleter> CreateScopedFoo() {
58 return std::unique_ptr<Foo, FooDeleter>(new Foo);
61 void ExpectScopedFoo(std::unique_ptr<Foo, FooDeleter> foo) {
62 EXPECT_TRUE(foo.get());
63 std::unique_ptr<Foo, FooDeleter> local_foo(std::move(foo));
64 EXPECT_TRUE(local_foo.get());
65 EXPECT_FALSE(foo.get());
68 struct FooWithoutDefaultConstructor {
69 explicit FooWithoutDefaultConstructor(int value) : value(value) {}
73 FooWithoutDefaultConstructor CreateFooWithoutDefaultConstructor(int value) {
74 return FooWithoutDefaultConstructor(value);
77 void SaveFooWithoutDefaultConstructor(int* output_value,
78 FooWithoutDefaultConstructor input) {
79 *output_value = input.value;
82 class TaskRunnerTest : public testing::Test {
84 TaskRunnerTest() = default;
86 void SetUp() override {
87 g_foo_destruct_count = 0;
94 TEST_F(TaskRunnerTest, PostTaskAndReplyWithResult) {
97 test::SingleThreadTaskEnvironment task_environment;
98 ThreadTaskRunnerHandle::Get()->PostTaskAndReplyWithResult(
99 FROM_HERE, BindOnce(&ReturnFourtyTwo), BindOnce(&StoreValue, &result));
101 RunLoop().RunUntilIdle();
103 EXPECT_EQ(42, result);
106 TEST_F(TaskRunnerTest, PostTaskAndReplyWithResultImplicitConvert) {
109 test::SingleThreadTaskEnvironment task_environment;
110 ThreadTaskRunnerHandle::Get()->PostTaskAndReplyWithResult(
111 FROM_HERE, BindOnce(&ReturnFourtyTwo),
112 BindOnce(&StoreDoubleValue, &result));
114 RunLoop().RunUntilIdle();
116 EXPECT_DOUBLE_EQ(42.0, result);
119 TEST_F(TaskRunnerTest, PostTaskAndReplyWithResultPassed) {
120 test::SingleThreadTaskEnvironment task_environment;
121 ThreadTaskRunnerHandle::Get()->PostTaskAndReplyWithResult(
122 FROM_HERE, BindOnce(&CreateFoo), BindOnce(&ExpectFoo));
124 RunLoop().RunUntilIdle();
126 EXPECT_EQ(1, g_foo_destruct_count);
127 EXPECT_EQ(0, g_foo_free_count);
130 TEST_F(TaskRunnerTest, PostTaskAndReplyWithResultPassedFreeProc) {
131 test::SingleThreadTaskEnvironment task_environment;
132 ThreadTaskRunnerHandle::Get()->PostTaskAndReplyWithResult(
133 FROM_HERE, BindOnce(&CreateScopedFoo), BindOnce(&ExpectScopedFoo));
135 RunLoop().RunUntilIdle();
137 EXPECT_EQ(1, g_foo_destruct_count);
138 EXPECT_EQ(1, g_foo_free_count);
141 TEST_F(TaskRunnerTest, PostTaskAndReplyWithResultWithoutDefaultConstructor) {
142 const int kSomeVal = 17;
144 test::SingleThreadTaskEnvironment task_environment;
147 ThreadTaskRunnerHandle::Get()->PostTaskAndReplyWithResult(
148 FROM_HERE, BindOnce(&CreateFooWithoutDefaultConstructor, kSomeVal),
149 BindOnce(&SaveFooWithoutDefaultConstructor, &actual));
151 RunLoop().RunUntilIdle();
153 EXPECT_EQ(kSomeVal, actual);