Tasks.cpp

Go to the documentation of this file.

#include "tarch/multicore/Task.h"
#include "tarch/Assertions.h"
#include "tarch/mpi/Rank.h"
#include "tarch/multicore/BooleanSemaphore.h"
#include "tarch/multicore/Core.h"
#include "tarch/multicore/Lock.h"
#include "tarch/multicore/multicore.h"
#include "tarch/services/ServiceRepository.h"
#include "tarch/multicore/sycl/Core.h"
 
#if defined(SharedSYCL)
 
namespace {
  tarch::multicore::BooleanSemaphore suspensionPointSemaphore;
} // namespace
 
void tarch::multicore::native::spawnAndWaitAsTaskLoop(const std::vector<tarch::multicore::Task*>& tasks) {
  assertion(not tasks.empty());
 
  for (auto& p : tasks) {
    tarch::multicore::getHostSYCLQueue().submit([&](auto& h) {
      while (p->run()) {
      }
      delete p;
    });
  }
 
  tarch::multicore::getHostSYCLQueue().wait();
}
 
 
void tarch::multicore::native::spawnTask(Task* job, int in, int out) { tarch::multicore::native::spawnTask(job); }
 
 
void tarch::multicore::native::spawnTask(Task* job) {
  sycl::event e = tarch::multicore::getHostSYCLQueue().submit([&](auto& h) {
    h.host_task([=]() {
      while (job->run()) {
      }
      delete job;
    });
  });
}
 
 
// void tarch::multicore::native::drainTaskQueues() { tarch::multicore::getHostSYCLQueue().wait(); }
 
 
void tarch::multicore::native::spawnTaskWithDependencies(Task* job, int inDependency, int taskNumber) {
  tarch::multicore::native::spawnTask(job);
}
 
 
void tarch::multicore::native::spawnTaskWithDependencies(
  Task* job, const std::vector<int>& inDependencies, int taskNumber
) {
  tarch::multicore::native::spawnTask(job);
}
 
 
void tarch::multicore::native::waitForTasks(const std::vector<int>& inDependencies) {}
 
void tarch::multicore::native::waitForTask(int taskNumber) {}
#endif