summaryrefslogtreecommitdiff
path: root/chromium/third_party/nearby/src/cpp/platform/public/single_thread_executor_test.cc
diff options
context:
space:
mode:
Diffstat (limited to 'chromium/third_party/nearby/src/cpp/platform/public/single_thread_executor_test.cc')
-rw-r--r--chromium/third_party/nearby/src/cpp/platform/public/single_thread_executor_test.cc139
1 files changed, 0 insertions, 139 deletions
diff --git a/chromium/third_party/nearby/src/cpp/platform/public/single_thread_executor_test.cc b/chromium/third_party/nearby/src/cpp/platform/public/single_thread_executor_test.cc
deleted file mode 100644
index f610578fb82..00000000000
--- a/chromium/third_party/nearby/src/cpp/platform/public/single_thread_executor_test.cc
+++ /dev/null
@@ -1,139 +0,0 @@
-// Copyright 2020 Google LLC
-//
-// Licensed under the Apache License, Version 2.0 (the "License");
-// you may not use this file except in compliance with the License.
-// You may obtain a copy of the License at
-//
-// https://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing, software
-// distributed under the License is distributed on an "AS IS" BASIS,
-// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-// See the License for the specific language governing permissions and
-// limitations under the License.
-
-#include "platform/public/single_thread_executor.h"
-
-#include <atomic>
-#include <functional>
-#include <string>
-
-#include "gtest/gtest.h"
-#include "absl/synchronization/mutex.h"
-#include "absl/time/clock.h"
-#include "platform/base/exception.h"
-
-namespace location {
-namespace nearby {
-
-TEST(SingleThreadExecutorTest, ConsructorDestructorWorks) {
- SingleThreadExecutor executor;
-}
-
-TEST(SingleThreadExecutorTest, CanExecute) {
- absl::CondVar cond;
- std::atomic_bool done = false;
- SingleThreadExecutor executor;
- executor.Execute([&done, &cond]() {
- done = true;
- cond.SignalAll();
- });
- absl::Mutex mutex;
- {
- absl::MutexLock lock(&mutex);
- if (!done) {
- cond.WaitWithTimeout(&mutex, absl::Seconds(1));
- }
- }
- EXPECT_TRUE(done);
-}
-
-TEST(SingleThreadExecutorTest, CanExecuteNamedTask) {
- absl::CondVar cond;
- std::atomic_bool done = false;
- SingleThreadExecutor executor;
- executor.Execute("my task", [&done, &cond]() {
- done = true;
- cond.SignalAll();
- });
- absl::Mutex mutex;
- {
- absl::MutexLock lock(&mutex);
- if (!done) {
- cond.WaitWithTimeout(&mutex, absl::Seconds(1));
- }
- }
- EXPECT_TRUE(done);
-}
-
-TEST(SingleThreadExecutorTest, JobsExecuteInOrder) {
- std::vector<int> results;
- SingleThreadExecutor executor;
-
- for (int i = 0; i < 10; ++i) {
- executor.Execute([i, &results]() { results.push_back(i); });
- }
-
- absl::CondVar cond;
- std::atomic_bool done = false;
- executor.Execute([&done, &cond]() {
- done = true;
- cond.SignalAll();
- });
- absl::Mutex mutex;
- {
- absl::MutexLock lock(&mutex);
- if (!done) {
- cond.WaitWithTimeout(&mutex, absl::Seconds(1));
- }
- }
- EXPECT_TRUE(done);
- EXPECT_EQ(results, (std::vector<int>{0, 1, 2, 3, 4, 5, 6, 7, 8, 9}));
-}
-
-TEST(SingleThreadExecutorTest, CanSubmit) {
- SingleThreadExecutor executor;
- Future<bool> future;
- bool submitted =
- executor.Submit<bool>([]() { return ExceptionOr<bool>{true}; }, &future);
- EXPECT_TRUE(submitted);
- EXPECT_TRUE(future.Get().result());
-}
-
-struct ThreadCheckTestClass {
- SingleThreadExecutor executor;
- int value ABSL_GUARDED_BY(executor) = 0;
-
- void incValue() ABSL_EXCLUSIVE_LOCKS_REQUIRED(executor) { value++; }
- int getValue() ABSL_EXCLUSIVE_LOCKS_REQUIRED(executor) { return value; }
-};
-
-TEST(SingleThreadExecutorTest, ThreadCheck_ExecuteRunnable) {
- ThreadCheckTestClass test_class;
-
- test_class.executor.Execute(
- [&test_class]() ABSL_EXCLUSIVE_LOCKS_REQUIRED(test_class.executor) {
- test_class.incValue();
- });
-}
-
-TEST(SingleThreadExecutorTest, ThreadCheck_SubmitCallable) {
- ThreadCheckTestClass test_class;
- test_class.executor.Execute(
- [&test_class]() ABSL_EXCLUSIVE_LOCKS_REQUIRED(test_class.executor) {
- test_class.incValue();
- });
- Future<int> future;
-
- bool submitted = test_class.executor.Submit<int>(
- [&test_class]() ABSL_EXCLUSIVE_LOCKS_REQUIRED(test_class.executor) {
- return ExceptionOr<int>{test_class.getValue()};
- },
- &future);
-
- EXPECT_TRUE(submitted);
- EXPECT_EQ(future.Get().result(), 1);
-}
-
-} // namespace nearby
-} // namespace location