27 lines
666 B
C++
27 lines
666 B
C++
|
#include "reduce_sum.hpp"
|
||
|
|
#include <taskflow/taskflow.hpp>
|
||
|
|
#include <taskflow/algorithm/reduce.hpp>
|
||
|
|
|
||
|
|
void reduce_sum_taskflow(unsigned num_threads) {
|
||
|
|
|
||
|
|
tf::Executor executor(num_threads);
|
||
|
|
tf::Taskflow taskflow;
|
||
|
|
|
||
|
|
double result;
|
||
|
|
|
||
|
|
taskflow.reduce(vec.begin(), vec.end(), result, [](double l, double r){
|
||
|
|
return l + r;
|
||
|
|
});
|
||
|
|
|
||
|
|
executor.run(taskflow).get();
|
||
|
|
}
|
||
|
|
|
||
|
|
std::chrono::microseconds measure_time_taskflow(unsigned num_threads) {
|
||
|
|
auto beg = std::chrono::high_resolution_clock::now();
|
||
|
|
reduce_sum_taskflow(num_threads);
|
||
|
|
auto end = std::chrono::high_resolution_clock::now();
|
||
|
|
return std::chrono::duration_cast<std::chrono::microseconds>(end - beg);
|
||
|
|
}
|
||
|
|
|
||
|
|
|