graph_thread.h

// SPDX-FileCopyrightText: © 2019-2021, 2024 Alexandros Theodotou <alex@zrythm.org>
// SPDX-License-Identifier: LicenseRef-ZrythmLicense
 
#pragma once
 
#include "zrythm-config.h"
 
#include "utils/rt_thread_id.h"
 
#include "juce_wrapper.h"
 
namespace zrythm::dsp::graph
{
 
class GraphScheduler;

class GraphThread final : public juce::Thread
{
public:
  explicit GraphThread (
    int                                 id,
    bool                                is_main,
    GraphScheduler                     &scheduler,
    std::optional<juce::AudioWorkgroup> workgroup = std::nullopt);
  ~GraphThread () override;
 
public:
  [[gnu::hot]] void on_reached_terminal_node ();
 
private:
  void run () override;

  void run_worker () noexcept [[clang::nonblocking]];
 
public:
  int id_{ -1 };
 
  bool is_main_{ false };

  std::atomic<RTThreadId::IdType> rt_thread_id_{ 0 };

  GraphScheduler &scheduler_;

  std::optional<juce::AudioWorkgroup> audio_workgroup_;
 
private:
  std::atomic<bool> thread_finished_{ false };
};
 
} // namespace zrythm::dsp::graph