108 lines
2.8 KiB
C++
108 lines
2.8 KiB
C++
// Copyright (C) 2014 The Android Open Source Project
|
|
//
|
|
// 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
|
|
//
|
|
// http://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 "emugl/common/mutex.h"
|
|
|
|
#include "emugl/common/testing/test_thread.h"
|
|
|
|
#include <gtest/gtest.h>
|
|
|
|
namespace emugl {
|
|
|
|
// Check that construction and destruction doesn't crash.
|
|
TEST(Mutex, ConstructionDestruction) {
|
|
Mutex lock;
|
|
}
|
|
|
|
// Check that a simple lock + unlock works.
|
|
TEST(Mutex, LockUnlock) {
|
|
Mutex lock;
|
|
lock.lock();
|
|
lock.unlock();
|
|
}
|
|
|
|
// Check that AutoLock compiles and doesn't crash.
|
|
TEST(Mutex, AutoLock) {
|
|
Mutex mutex;
|
|
Mutex::AutoLock lock(mutex);
|
|
}
|
|
|
|
// Wrapper class for threads. Does not use emugl::Thread intentionally.
|
|
// Common data type used by the following tests below.
|
|
struct ThreadParams {
|
|
ThreadParams() : mutex(), counter(0) {}
|
|
|
|
Mutex mutex;
|
|
int counter;
|
|
};
|
|
|
|
// This thread function uses Mutex::lock/unlock to synchronize a counter
|
|
// increment operation.
|
|
static void* threadFunction(void* param) {
|
|
ThreadParams* p = static_cast<ThreadParams*>(param);
|
|
|
|
p->mutex.lock();
|
|
p->counter++;
|
|
p->mutex.unlock();
|
|
return NULL;
|
|
}
|
|
|
|
TEST(Mutex, Synchronization) {
|
|
const size_t kNumThreads = 2000;
|
|
TestThread* threads[kNumThreads];
|
|
ThreadParams p;
|
|
|
|
// Create and launch all threads.
|
|
for (size_t n = 0; n < kNumThreads; ++n) {
|
|
threads[n] = new TestThread(threadFunction, &p);
|
|
}
|
|
|
|
// Wait until their completion.
|
|
for (size_t n = 0; n < kNumThreads; ++n) {
|
|
threads[n]->join();
|
|
delete threads[n];
|
|
}
|
|
|
|
EXPECT_EQ(static_cast<int>(kNumThreads), p.counter);
|
|
}
|
|
|
|
// This thread function uses a Mutex::AutoLock to protect the counter.
|
|
static void* threadAutoLockFunction(void* param) {
|
|
ThreadParams* p = static_cast<ThreadParams*>(param);
|
|
|
|
Mutex::AutoLock lock(p->mutex);
|
|
p->counter++;
|
|
return NULL;
|
|
}
|
|
|
|
TEST(Mutex, AutoLockSynchronization) {
|
|
const size_t kNumThreads = 2000;
|
|
TestThread* threads[kNumThreads];
|
|
ThreadParams p;
|
|
|
|
// Create and launch all threads.
|
|
for (size_t n = 0; n < kNumThreads; ++n) {
|
|
threads[n] = new TestThread(threadAutoLockFunction, &p);
|
|
}
|
|
|
|
// Wait until their completion.
|
|
for (size_t n = 0; n < kNumThreads; ++n) {
|
|
threads[n]->join();
|
|
delete threads[n];
|
|
}
|
|
|
|
EXPECT_EQ(static_cast<int>(kNumThreads), p.counter);
|
|
}
|
|
|
|
} // namespace emugl
|