thread.hpp

Go to the documentation of this file.

// SPDX-License-Identifier: MIT
// Author:  Giovanni Santini
// Mail:    giovanni.santini@proton.me
// Github:  @San7o
 
#pragma once
 
#include <thread> // based on thread
 
namespace tenno
{
 
class jthread
{
public:
  using native_handle_type = std::thread::native_handle_type;
 
  std::thread::id id;
 
  jthread() noexcept = default;
  jthread(const jthread &) = delete;
 
  jthread(jthread &&other) noexcept
  {
    this->_inner_thread = std::move(other._inner_thread);
    this->id = this->_inner_thread.get_id();
  }
 
  template <class F, class... Args> explicit jthread(F &&f, Args &&...args)
  {
    this->_inner_thread = std::thread(f, args...);
    this->id = this->_inner_thread.get_id();
  }
 
  ~jthread()
  {
    if (this->joinable())
    {
      this->_inner_thread.join();
    }
  }
 
  bool joinable() const noexcept
  {
    return this->_inner_thread.joinable();
  }
 
  std::thread::id get_id() const noexcept
  {
    return this->_inner_thread.get_id();
  }
 
  native_handle_type native_handle()
  {
    return this->_inner_thread.native_handle();
  }
 
  static unsigned int hardware_concurrency() noexcept
  {
    return std::thread::hardware_concurrency();
  }
 
  void join()
  {
    this->_inner_thread.join();
  }
 
  void detach()
  {
    this->_inner_thread.detach();
  }
 
  void swap(tenno::jthread &other) noexcept
  {
    this->_inner_thread.swap(other._inner_thread);
    this->id = this->_inner_thread.get_id();
    other.id = other._inner_thread.get_id();
  }
 
#if __cplusplus >= 202002L // C++20
  std::stop_source get_stop_source() noexcept
  {
    return this->_stop_source;
  }
 
  std::stop_token get_stop_token() const noexcept
  {
    return this->_stop_source.get_token();
  }
 
  bool request_stop() noexcept
  {
    return this->_stop_source.request_stop();
  }
#endif
 
private:
  std::thread _inner_thread;
#if __cplusplus >= 202002L // C++20
  std::stop_source _stop_source;
#endif
};
 
} // namespace tenno