ProcessSetOfReadyTasks.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 "tarch/logging/Log.h"
#include "tarch/multicore/multicore.h"
#include "tarch/multicore/Task.h"
#include "tarch/multicore/TaskEnumerator.h"
#include "tarch/multicore/taskfusion/taskfusion.h"
 
 
namespace tarch {
  namespace multicore {
    namespace taskfusion {
      class LogReadyTask;
      class ProcessSetOfReadyTasks;
      struct FusableTasksQueue;
    }
  }
}
 
 
class tarch::multicore::taskfusion::ProcessSetOfReadyTasks: public tarch::multicore::Task {
  private:
    FusableTasksQueue& _taskQueue;
    const int          _taskNumber;
 
    const bool          _administerYourOwnTemporaryTaskLocalNumber;
 
    static tarch::logging::Log  _log;
 
 
    static const std::string    ProcessFusedTasksStatisticsIdentifier;
 
    void processFusedTask(Task* myTask, const std::vector<tarch::multicore::Task*>& tasksOfSameType, int device);
 
    static tarch::multicore::TaskEnumerator _enumerator;
  public:
    static constexpr TaskNumber AdministerYourOwnTemporaryTaskLocalNumber = -3;
 
    ProcessSetOfReadyTasks(
      TaskNumber          taskNumber,
      FusableTasksQueue&  taskQueue
    );
 
    virtual void run() override;
 
    TaskNumber getNumber() const;
};