ParallelForSYCL.h

Go to the documentation of this file.

// ----------------------------------------------------------------------------
// -                        CloudViewer: www.cloudViewer.org                  -
// ----------------------------------------------------------------------------
// Copyright (c) 2018-2024 www.cloudViewer.org
// SPDX-License-Identifier: MIT
// ----------------------------------------------------------------------------
 
#pragma once
 
#include <Logging.h>
 
#include <cstdint>
#include <type_traits>
 
#include "cloudViewer/core/Device.h"
#include "cloudViewer/core/Indexer.h"
#include "cloudViewer/core/SYCLContext.h"
 
namespace cloudViewer {
namespace core {
 
template <typename Functor, typename... FuncArgs>
void ParallelForSYCL(const Device& device,
                     Indexer indexer,
                     FuncArgs... func_args) {
    if (!device.IsSYCL()) {
        utility::LogError("ParallelFor for SYCL cannot run on device {}.",
                          device.ToString());
    }
    int64_t n = indexer.NumWorkloads();
    if (n == 0) {
        return;
    }
    auto queue = sy::SYCLContext::GetInstance().GetDefaultQueue(device);
    queue.parallel_for<Functor>(n, [indexer, func_args...](int64_t i) {
             Functor ef(indexer, func_args...);
             ef(i);
         }).wait_and_throw();
}
 
template <typename Functor, typename... FuncArgs>
void ParallelForSYCL(const Device& device,
                     int64_t num_workloads,
                     FuncArgs... func_args) {
    if (!device.IsSYCL()) {
        utility::LogError("ParallelFor for SYCL cannot run on device {}.",
                          device.ToString());
    }
    if (num_workloads == 0) {
        return;
    }
    auto queue = sy::SYCLContext::GetInstance().GetDefaultQueue(device);
    queue.parallel_for<Functor>(num_workloads, [func_args...](int64_t i) {
             Functor ef(func_args...);
             ef(i);
         }).wait_and_throw();
}
 
}  // namespace core
}  // namespace cloudViewer