From 783367773875fd2ee37c4be81b90f1fa98dfbe15 Mon Sep 17 00:00:00 2001 From: "Scott E. Graves" Date: Fri, 23 Aug 2024 17:01:05 -0500 Subject: [PATCH] cleanup --- .../include/utils/action_queue.hpp | 49 ------------------- .../librepertory/src/utils/action_queue.cpp | 21 -------- 2 files changed, 70 deletions(-) delete mode 100644 repertory/librepertory/include/utils/action_queue.hpp delete mode 100644 repertory/librepertory/src/utils/action_queue.cpp diff --git a/repertory/librepertory/include/utils/action_queue.hpp b/repertory/librepertory/include/utils/action_queue.hpp deleted file mode 100644 index 6f8ffe0f..00000000 --- a/repertory/librepertory/include/utils/action_queue.hpp +++ /dev/null @@ -1,49 +0,0 @@ -/* - Copyright <2018-2024> - - Permission is hereby granted, free of charge, to any person obtaining a copy - of this software and associated documentation files (the "Software"), to deal - in the Software without restriction, including without limitation the rights - to use, copy, modify, merge, publish, distribute, sublicense, and/or sell - copies of the Software, and to permit persons to whom the Software is - furnished to do so, subject to the following conditions: - - The above copyright notice and this permission notice shall be included in all - copies or substantial portions of the Software. - - THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR - IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, - FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE - AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER - LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, - OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE - SOFTWARE. -*/ -#ifndef INCLUDE_UTILS_ACTION_QUEUE_HPP_ -#define INCLUDE_UTILS_ACTION_QUEUE_HPP_ - -#include "utils/single_thread_service_base.hpp" - -namespace repertory::utils::action_queue { -class action_queue final : single_thread_service_base { - explicit action_queue(const std::string &id, - std::uint8_t max_concurrent_actions = 5u); - -private: - std::string id_; - std::uint8_t max_concurrent_actions_; - -private: - std::deque> queue_; - mutable std::mutex queue_mtx_; - std::condition_variable queue_notify_; - -protected: - void service_function() override; - -public: - void push(std::function action); -}; -} // namespace repertory::utils::action_queue - -#endif // INCLUDE_UTILS_ACTION_QUEUE_HPP_ diff --git a/repertory/librepertory/src/utils/action_queue.cpp b/repertory/librepertory/src/utils/action_queue.cpp deleted file mode 100644 index 7cd9d76c..00000000 --- a/repertory/librepertory/src/utils/action_queue.cpp +++ /dev/null @@ -1,21 +0,0 @@ -#include "utils/action_queue.hpp" - -#include "types/repertory.hpp" - -namespace repertory::utils::action_queue { -action_queue::action_queue(const std::string &id, - std::uint8_t max_concurrent_actions) - : single_thread_service_base("action_queue_" + id), - id_(id), - max_concurrent_actions_(max_concurrent_actions) {} - -void action_queue::service_function() { - // -} - -void action_queue::push(std::function action) { - unique_mutex_lock queue_lock(queue_mtx_); - queue_.emplace_back(action); - queue_notify_.notify_all(); -} -} // namespace repertory::utils::action_queue