#include <random>

#include <nexus/async.h>

#include <nexus/pool.h>

void asyncFunction(int i) {

for (int i = 0; i < 100000000; i++) {

continue;

}

logger::warning("Async task " + std::to_string(i) + " finished");

}

int main() {

// By default, nexus uses all available threads

// If you would prefer to use a specific number of threads, you can pass the

// number of threads to the pool constructor

nexus::pool pool;

std::vector<std::future<std::string>> results;

for (int i = 0; i < 500; ++i) {

nexus::async(asyncFunction, i);

}

for (int i = 0; i < 500; ++i) {

results.emplace_back(pool.enqueue([i] {

for (int j = 0; j < 100000000; j++) {

continue;

}

logger::success("Task " + std::to_string(i) + " finished");

return std::to_string(i) + " -> " + std::to_string(rand() % 2 == 0);

}));

}

for (std::future<std::string> &result : results) {

logger::info("Result: " + result.get());

}

return EXIT_SUCCESS;

}