taskfusion.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
#pragma once
 
 
#include <unordered_set>
#include <list>
 
#include "tarch/multicore/multicore.h"
#include "tarch/multicore/BooleanSemaphore.h"
#include "tarch/timing/GlidingAverageMeasurement.h"
 
 
namespace tarch {
  namespace multicore {
    class Task;
 
    namespace taskfusion {
      struct ReadyFusableTasks {
        ~ReadyFusableTasks()                       = default;
        ReadyFusableTasks(const ReadyFusableTasks&) = delete;
 
        using Tasks = std::list< std::pair<tarch::multicore::Task*, int> >;
        using FinishedTaskNumbers = std::unordered_set<int>;
 
        Tasks                                      tasks;
        FinishedTaskNumbers                        completedTaskNumbers;
        tarch::multicore::BooleanSemaphore         semaphore;
        int                                        type;
        tarch::timing::GlidingAverageMeasurement   numberOfPendingReadyTasksPerProcessTaskExecution;
 
        ReadyFusableTasks(int type_):
          type(type_) {}
      };
 
      void translateFusableTaskIntoTaskSequence(
        Task*                        task,
        const std::set<TaskNumber>&  inDependencies,
        const TaskNumber&            taskNumber
      );
 
      void processAllReadyTasks();
    } // namespace taskfusion
  }
}