concurrence.hpp

Go to the documentation of this file.

// Copyright (C) 2025 Georgia Tech Research Institute
// Supported by USDA-NIFA CSIAPP Grant. No. 2023-70442-39232
//
// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
//
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License
// along with this program.  If not, see <https://www.gnu.org/licenses/>.
 
#ifndef YASMIN__CONCURRENCE_HPP
#define YASMIN__CONCURRENCE_HPP
 
#include <atomic>
#include <iostream>
#include <map>
#include <memory>
#include <mutex>
#include <set>
#include <string>
#include <thread>
#include <vector>
 
#ifdef __GNUG__     // If using GCC/G++
#include <cxxabi.h> // For abi::__cxa_demangle
#endif
 
#include "yasmin/blackboard/blackboard.hpp"
#include "yasmin/state.hpp"
 
namespace yasmin {

class Concurrence : public State {
 
public:
  typedef std::map<std::shared_ptr<State>, std::string> StateMap;
  typedef std::map<std::string, StateMap> OutcomeMap;
 
protected:
  const std::set<std::shared_ptr<State>> states;

  const std::string default_outcome;

  OutcomeMap outcome_map;

  std::map<std::shared_ptr<State>, std::shared_ptr<std::string>>
      intermediate_outcome_map;

  std::set<std::string> possible_outcomes;
 
private:
  std::atomic_bool canceled{false};
  std::atomic_bool running{false};

  std::mutex intermediate_outcome_mutex;

  static std::set<std::string>
  generate_possible_outcomes(const OutcomeMap &outcome_map,
                             const std::string &default_outcome);
 
public:
  Concurrence(std::set<std::shared_ptr<State>> states,
              std::string default_outcome, OutcomeMap outcome_map);

  std::string
  execute(std::shared_ptr<blackboard::Blackboard> blackboard) override;

  void cancel_state() override;

  std::string to_string() override {
    std::string name = typeid(*this).name();
 
#ifdef __GNUG__ // If using GCC/G++
    int status;
    // Demangle the name using GCC's demangling function
    char *demangled =
        abi::__cxa_demangle(name.c_str(), nullptr, nullptr, &status);
    if (status == 0) {
      name = demangled;
    }
    free(demangled);
#endif
 
    name += "[";
 
    for (auto it = states.begin(); it != states.end(); ++it) {
      name += (*it)->to_string();
 
      // Add a comma if this is not the last element
      if (std::next(it) != states.end()) {
        name += ", ";
      }
    }
 
    name += "]";
 
    return name; // Return the demangled class name
  }
};
 
} // namespace yasmin
 
#endif // YASMIN__CONCURRENCE_HPP