cpp-taskflow/benchmark/parallel_dnn/main.cpp at master · cppwanderboy/cpp-taskflow · GitHub

History

104 lines (84 loc) · 3.09 KB

Raw

100

101

102

103

#include <thread>

#include <iomanip>

#include <CLI11.hpp>

#include "dnn.hpp"

// Function: measure_time_taskflow

std::chrono::milliseconds measure_time_taskflow(

unsigned num_iterations,

unsigned num_threads

) {

auto t1 = std::chrono::high_resolution_clock::now();

run_taskflow(num_iterations, num_threads);

auto t2 = std::chrono::high_resolution_clock::now();

return std::chrono::duration_cast<std::chrono::milliseconds>(t2 - t1);

}

// Function: measure_time_omp

std::chrono::milliseconds measure_time_omp(

unsigned num_iterations,

unsigned num_threads

) {

auto t1 = std::chrono::high_resolution_clock::now();

run_omp(num_iterations, num_threads);

auto t2 = std::chrono::high_resolution_clock::now();

return std::chrono::duration_cast<std::chrono::milliseconds>(t2 - t1);

}

// Function: measure_time_tbb

std::chrono::milliseconds measure_time_tbb(

unsigned num_iterations,

unsigned num_threads

) {

auto t1 = std::chrono::high_resolution_clock::now();

run_tbb(num_iterations, num_threads);

auto t2 = std::chrono::high_resolution_clock::now();

return std::chrono::duration_cast<std::chrono::milliseconds>(t2 - t1);

}

// Function: main

int main(int argc, char *argv[]){

CLI::App app{"Hyperparameter Search"};

unsigned num_threads {1};

app.add_option("-t,--num_threads", num_threads, "number of threads (default=1)");

unsigned num_epochs {10};

app.add_option("-e,--num_epochs", num_epochs, "number of epochs (default=10)");

unsigned num_rounds {1};

app.add_option("-r,--num_rounds", num_rounds, "number of rounds (default=1)");

std::string model = "tf";

app.add_option("-m,--model", model, "model name tbb|omp|tf (default=tf)")

->check([] (const std::string& m) {

if(m != "tbb" && m != "omp" && m != "tf") {

return "model name should be \"tbb\", \"omp\", or \"tf\"";

}

return "";

});

CLI11_PARSE(app, argc, argv);

{

std::string path = std::experimental::filesystem::current_path();

path = path.substr(0, path.rfind("cpp-taskflow") + 12);

path += "/benchmark/parallel_dnn/";

IMAGES = read_mnist_image(path + "./train-images.data");

LABELS = read_mnist_label(path + "./train-labels.data");

TEST_IMAGES = read_mnist_image(path + "./t10k-images-idx3-ubyte");

TEST_LABELS = read_mnist_label(path + "./t10k-labels-idx1-ubyte");

}

::srand(0);

double runtime {0.0};

for(unsigned i=0; i<num_rounds; i++) {

std::cout << 'r' << i << ' '

<< "model=" << model << ' '

<< "num_threads=" << num_threads << ' '

<< "num_rounds=" << num_rounds << ' '

<< "num_epochs=" << num_epochs << ' '

<< std::flush;

if(model == "tf") {

runtime += measure_time_taskflow(num_epochs, num_threads).count();

}

else if(model == "tbb") {

runtime += measure_time_tbb(num_epochs, num_threads).count();

}

else if(model == "omp") {

runtime += measure_time_omp(num_epochs, num_threads).count();

}

else assert(false);

std::cout << "avg_cpu(s)=" << runtime / (i+1) / 1e3 << std::endl;

}

return EXIT_SUCCESS;

}

cpp-taskflow/benchmark/parallel_dnn/main.cpp at master · cppwanderboy/cpp-taskflow · GitHub

Expand file tree

Breadcrumbs

main.cpp

Latest commit

History

Breadcrumbs

main.cpp

File metadata and controls