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 <Windows.h>  // シリアル通信を行うために必要.
 
#include <boost/thread.hpp>
#include <string>
#include <vector>
 
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_