serial_communication_thread.h

[詳解]

 
 
// Copyright(c) 2023-2025 Design Engineering Laboratory, Saitama University
// Released under the MIT license
// https://opensource.org/licenses/mit-license.php
 
#ifndef DESIGNLAB_SERIAL_COMMUNICATION_THREAD_H_
#define DESIGNLAB_SERIAL_COMMUNICATION_THREAD_H_
 
#include <string>
#include <vector>
 
#include <boost/thread.hpp>
 
#include <Windows.h>  // シリアル通信を行うために必要．
 
 
namespace designlab
{
 
class SerialCommunicationThread final
{
public:
    SerialCommunicationThread() = default;
    ~SerialCommunicationThread() = default;
 
    void Loop();
 
    void SetWriteData(const std::string& str);
 
    std::string GetTopReadData() const;
 
    std::vector<std::string> GetAllReadData() const;
 
    std::vector<std::string> GetReadData(const int num) const;
 
    void EndThread()
    {
        boost::mutex::scoped_lock lock(mutex_);
        end_flag_ = true;
    }
 
    bool IsEnd() const
    {
        boost::mutex::scoped_lock lock(mutex_);
        return end_flag_;
    }
 
private:
    static constexpr float kThreadPeriod = 0.01f;  
    static constexpr int kBufferSize = 1024;  
    static constexpr int kComPortNumber = 3;  
 
    bool Initialize();
 
    bool Read();
 
    bool Write();
 
    HANDLE serial_handle_{ INVALID_HANDLE_VALUE };  
 
    std::vector<std::string> read_data_;  
    std::string write_data_;  
 
    bool end_flag_{ false };  
 
    mutable boost::mutex mutex_;  
};
 
}  // namespace designlab
 
 
#endif  // DESIGNLAB_SERIAL_COMMUNICATION_THREAD_H_