Add benchmark example

Author: IYP-Programer-Yeah

Example/Benchmark/Source/main.cpp

@@ -0,0 +1,64 @@
+#include <Iyp/WaitFreeRingBufferUtilities/wait-free-ring-buffer-utilities.inl>
+
+#include <vector>
+#include <thread>
+#include <atomic>
+#include <iostream>
+#include <chrono>
+#include <cstdlib>
+
+int main()
+{
+	constexpr static std::size_t RingSize = 4096;
+	using RingBufferType = Iyp::WaitFreeRingBufferUtilities::RingBuffer<std::size_t,
+																		Iyp::WaitFreeRingBufferUtilities::AccessRequirements::MULTI_CONSUMER |
+																			Iyp::WaitFreeRingBufferUtilities::AccessRequirements::MULTI_PRODUCER,
+																		RingSize>;
+	constexpr std::size_t PushCount = 4096 * RingSize;
+	constexpr std::size_t NumberOfPusherThreads = 4;
+	constexpr std::size_t NumberOfPopperThreads = 4;
+
+	std::vector<std::thread> pushers;
+	std::vector<std::thread> poppers;
+	RingBufferType ring;
+
+	for (std::size_t thread_number = 0; thread_number < NumberOfPopperThreads; thread_number++)
+	{
+		poppers.emplace_back([&ring, PushCount, NumberOfPusherThreads, NumberOfPopperThreads]() {
+			for (std::size_t i = 0; i < PushCount * NumberOfPusherThreads / NumberOfPopperThreads; i++)
+				while (!ring.pop())
+				{
+				}
+		});
+	}
+
+	std::atomic<bool> do_push;
+
+	for (std::size_t thread_number = 0; thread_number < NumberOfPusherThreads; thread_number++)
+	{
+		pushers.emplace_back([&ring, &do_push, PushCount]() mutable {
+			while (!do_push.load(std::memory_order_relaxed))
+			{
+			}
+
+			for (std::size_t i = 0; i < PushCount; i++)
+				while (!ring.push(i))
+				{
+				}
+		});
+	}
+
+	const auto start_time = std::chrono::steady_clock::now();
+	do_push.store(true, std::memory_order_relaxed);
+
+	for (auto &popper : poppers)
+		popper.join();
+
+	const auto end_time = std::chrono::steady_clock::now();
+
+	std::cout << "Processed " << PushCount * NumberOfPusherThreads << " elements in ";
+	std::cout << std::chrono::nanoseconds{end_time - start_time}.count() << " nano-seconds." << std::endl;
+
+	for (auto &pusher : pushers)
+		pusher.join();
+}

Projects/CMake/CMakeLists.txt

@@ -16,4 +16,5 @@ add_subdirectory(googletest)
 add_subdirectory(boost)
 add_subdirectory(WaitFreeRingBufferUtilities)
 add_subdirectory(Test)
+add_subdirectory(Example)
 

Projects/CMake/Example/Benchmark/CMakeLists.txt

@@ -0,0 +1,18 @@
+project(Benchmark CXX)
+
+file(GLOB_RECURSE CPP_FILES ${REPO_ROOT}/Example/${PROJECT_NAME}/Source/*.cpp)
+add_executable(${PROJECT_NAME} ${CPP_FILES})
+find_package(Threads REQUIRED)
+target_link_libraries(${PROJECT_NAME} WaitFreeRingBufferUtilities Threads::Threads)
+
+if(WIN32)
+	install(TARGETS ${PROJECT_NAME}
+			LIBRARY DESTINATION Lib
+			RUNTIME DESTINATION Bin
+			ARCHIVE DESTINATION Lib)
+else()
+	install(TARGETS ${PROJECT_NAME}
+			LIBRARY DESTINATION lib
+			RUNTIME DESTINATION bin
+			ARCHIVE DESTINATION lib)
+endif()

Projects/CMake/Example/CMakeLists.txt

@@ -0,0 +1 @@
+add_subdirectory(Benchmark)

Projects/CMake/Test/CMakeLists.txt

@@ -5,7 +5,8 @@ include_directories(${LOCAL_INCLUDE_DIR})
 
 file(GLOB_RECURSE CPP_FILES ${REPO_ROOT}/${PROJECT_NAME}/Source/*.cpp)
 add_executable(${PROJECT_NAME} ${CPP_FILES})
-target_link_libraries(${PROJECT_NAME} gtest gtest_main WaitFreeRingBufferUtilities)
+find_package(Threads REQUIRED)
+target_link_libraries(${PROJECT_NAME} gtest gtest_main WaitFreeRingBufferUtilities Threads::Threads)
 
 if (MSVC)
 	set(CMAKE_CXX_FLAGS_RELEASE "${CMAKE_CXX_FLAGS_RELEASE} /MT")

Projects/CMake/boost/detail/CMakeLists.txt

@@ -1 +1 @@
-add_subdirectory(${REPO_ROOT}/Dependencies/boost/detail boost)
+add_subdirectory(${REPO_ROOT}/Dependencies/boost/detail boost/)

Projects/CMake/boost/move/CMakeLists.txt

@@ -1 +1 @@
-add_subdirectory(${REPO_ROOT}/Dependencies/boost/move boost)
+add_subdirectory(${REPO_ROOT}/Dependencies/boost/move boost/)