dynamic_task_graph_spawned_node.h

Go to the documentation of this file.

// This file is part of the Peano project. For conditions of distribution and
// use, please see the copyright notice at www.peano-framework.org. It
// supplements something to oneTBB which has been removed and which I need:
// dynamic tasking. Therefore I add it to the tbb namespace rather than
// Peano's tarch.
#pragma once
 
 
#include <functional>
#include <set>
#include <tbb/task_arena.h>
#include <oneapi/tbb/task_arena.h>
#include <oneapi/tbb/concurrent_hash_map.h>
#include <oneapi/tbb/spin_mutex.h>
 
 
namespace tbb {
  class dynamic_task_graph_node;
  class dynamic_task_graph_spawned_node;
  class dynamic_task_graph;
}
 
 
namespace tbb {
  class dynamic_task_graph_spawned_node {
    public:
      enum class State {
        Submitted,
 
        Spawned,
 
        Complete
      };
 
      dynamic_task_graph_spawned_node(
        const dynamic_task_graph_node&  task_specification,
        dynamic_task_graph&             task_graph
      );
 
      dynamic_task_graph_spawned_node(const dynamic_task_graph_spawned_node& ) = delete;
 
      void incoming_task_has_terminated();
 
      void add_incoming_task_dependency();
 
      void run();
 
      std::string to_string() const;
 
      bool add_successor( std::shared_ptr<dynamic_task_graph_spawned_node> successor );
 
      bool has_terminated() const;
    private:
      State                                           _state;
      std::function<void()>                           _functor;
 
      tbb::spin_mutex                                 _dependencies_semaphore;
      dynamic_task_graph&                             _task_graph;
      int                                             _number_of_in_dependencies;
      std::vector< std::shared_ptr<dynamic_task_graph_spawned_node> >   _out_dependency;
 
      #if TBB_USE_DEBUG>0
      std::string  _task_description;
      #endif
  };
 
}