-
Notifications
You must be signed in to change notification settings - Fork 182
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
ecal_thread back again :-) (now based on std::thread)
- Loading branch information
1 parent
a238c1c
commit aa39d7c
Showing
8 changed files
with
171 additions
and
67 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,112 @@ | ||
| /* ========================= eCAL LICENSE ================================= | ||
| * | ||
| * Copyright (C) 2016 - 2019 Continental Corporation | ||
| * | ||
| * 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. | ||
| * | ||
| * ========================= eCAL LICENSE ================================= | ||
| */ | ||
|
|
||
| /** | ||
| * @brief eCAL threading helper class | ||
| **/ | ||
|
|
||
| #include <chrono> | ||
| #include <condition_variable> | ||
| #include <functional> | ||
| #include <mutex> | ||
| #include <thread> | ||
|
|
||
| #pragma once | ||
|
|
||
| namespace eCAL | ||
| { | ||
| /** | ||
| * @brief A class that encapsulates threaded functionality with a callback interface. | ||
| */ | ||
| class CallbackThread { | ||
| public: | ||
| /** | ||
| * @brief Constructor for the CallbackThread class. | ||
| * @param callback A callback function to be executed in the CallbackThread thread. | ||
| */ | ||
| CallbackThread(std::function<void()> callback) | ||
| : callback_(callback), stopThread_(false) {} | ||
|
|
||
| /** | ||
| * @brief Start the callback thread with a specified timeout. | ||
| * @param timeout The timeout duration for waiting in the callback thread. | ||
| */ | ||
| template <typename DurationType> | ||
| void start(DurationType timeout) | ||
| { | ||
| callbackThread_ = std::thread(&CallbackThread::callbackFunction<DurationType>, this, timeout); | ||
| } | ||
|
|
||
| /** | ||
| * @brief Stop the callback thread. | ||
| * Waits for the callback thread to finish its work. | ||
| */ | ||
| void stop() | ||
| { | ||
| { | ||
| std::unique_lock<std::mutex> lock(mtx_); | ||
| // Set the flag to signal the callback thread to stop | ||
| stopThread_ = true; | ||
| // Notify the callback thread to wake up and check the flag | ||
| cv_.notify_one(); | ||
| } | ||
|
|
||
| // Wait for the callback thread to finish | ||
| if (callbackThread_.joinable()) { | ||
| callbackThread_.join(); | ||
| } | ||
| } | ||
|
|
||
| private: | ||
| std::thread callbackThread_; /**< The callback thread object. */ | ||
| std::function<void()> callback_; /**< The callback function to be executed in the callback thread. */ | ||
| std::mutex mtx_; /**< Mutex for thread synchronization. */ | ||
| std::condition_variable cv_; /**< Condition variable for signaling between threads. */ | ||
| bool stopThread_; /**< Flag to indicate whether the callback thread should stop. */ | ||
|
|
||
| /** | ||
| * @brief Callback function that runs in the callback thread. | ||
| * Periodically checks the stopThread flag and executes the callback function. | ||
| * @tparam DurationType The type of the timeout duration (e.g., std::chrono::seconds, std::chrono::milliseconds). | ||
| * @param timeout The timeout duration for waiting in the callback thread. | ||
| */ | ||
| template <typename DurationType> | ||
| void callbackFunction(DurationType timeout) | ||
| { | ||
| while (true) | ||
| { | ||
| { | ||
| std::unique_lock<std::mutex> lock(mtx_); | ||
| // Wait for a signal or a timeout | ||
| if (cv_.wait_for(lock, timeout, [this] { return stopThread_; })) | ||
| { | ||
| // If the stopThread flag is true, break out of the loop | ||
| break; | ||
| } | ||
| } | ||
|
|
||
| // Do some work in the callback thread | ||
| if (callback_) | ||
| { | ||
| callback_(); | ||
| } | ||
| } | ||
| } | ||
| }; | ||
| } |