mirror of
https://github.com/intel/compute-runtime.git
synced 2026-01-11 00:10:58 +08:00
f31304a9ad
Change-Id: I617e77f2680d6d22381b7fde702a551413295266 Signed-off-by: Bartosz Dunajski <bartosz.dunajski@intel.com>
54 lines
1.4 KiB
C++
54 lines
1.4 KiB
C++
/*
|
|
* Copyright (C) 2017-2020 Intel Corporation
|
|
*
|
|
* SPDX-License-Identifier: MIT
|
|
*
|
|
*/
|
|
|
|
#include "opencl/source/accelerators/intel_accelerator.h"
|
|
#include "opencl/source/command_queue/command_queue.h"
|
|
#include "opencl/source/platform/platform.h"
|
|
#include "opencl/test/unit_test/mocks/mock_command_queue.h"
|
|
|
|
#include "gtest/gtest.h"
|
|
|
|
namespace NEO {
|
|
|
|
TEST(BaseObjectTestsMt, givenObjectOwnershipForEachThreadWhenIncrementingNonAtomicValueThenNoDataRacesAreExpected) {
|
|
MockCommandQueue *object = new MockCommandQueue;
|
|
object->takeOwnership();
|
|
uint32_t counter = 0;
|
|
const uint32_t loopCount = 50;
|
|
const uint32_t numThreads = 3;
|
|
|
|
auto incrementNonAtomicValue = [&](CommandQueue *obj) {
|
|
for (uint32_t i = 0; i < loopCount; i++) {
|
|
obj->takeOwnership();
|
|
counter++;
|
|
obj->releaseOwnership();
|
|
}
|
|
};
|
|
|
|
EXPECT_EQ(0U, object->getCond().peekNumWaiters());
|
|
|
|
std::thread t1(incrementNonAtomicValue, object);
|
|
std::thread t2(incrementNonAtomicValue, object);
|
|
std::thread t3(incrementNonAtomicValue, object);
|
|
|
|
while (object->getCond().peekNumWaiters() != numThreads) {
|
|
std::this_thread::yield();
|
|
}
|
|
|
|
EXPECT_EQ(0u, counter);
|
|
object->releaseOwnership();
|
|
|
|
t1.join();
|
|
t2.join();
|
|
t3.join();
|
|
|
|
EXPECT_EQ(loopCount * numThreads, counter);
|
|
|
|
object->release();
|
|
}
|
|
} // namespace NEO
|