batch_operations.h

Go to the documentation of this file.

// BSD 3-Clause License
// Copyright (c) 2024, 🍀☀🌕🌥 🌊
// See the LICENSE file in the project root for full license information.
 
#pragma once
 
#include <future>
#include <vector>
#include <utility>
#include <type_traits>
 
namespace kcenon::thread {
 
namespace detail {
 
template<typename Container, typename Operation>
auto batch_apply(Container&& items, Operation&& op)
{
    using ResultType = decltype(op(std::move(*std::begin(items))));
    std::vector<ResultType> results;
    results.reserve(items.size());
 
    for (auto&& item : items) {
        results.push_back(op(std::move(item)));
    }
 
    return results;
}
 
template<typename T>
auto collect_all(std::vector<std::future<T>>& futures) -> std::vector<T>
{
    std::vector<T> results;
    results.reserve(futures.size());
 
    for (auto& future : futures) {
        results.push_back(future.get());
    }
 
    return results;
}
 
inline void collect_all(std::vector<std::future<void>>& futures)
{
    for (auto& future : futures) {
        future.get();
    }
}
 
} // namespace detail
 
} // namespace kcenon::thread