test.cpp

#include <exe/tp/thread_pool.hpp>
#include <exe/fibers/core/api.hpp>
#include <exe/fibers/sync/mutex.hpp>
#include <exe/fibers/sync/wait_group.hpp>
#include <wheels/support/stop_watch.hpp>

#include <iostream>
#include <chrono>

using namespace exe;
using namespace std::chrono_literals;

int main() {
  tp::ThreadPool scheduler{/*threads=*/4};

  fibers::Mutex m;

  auto task = [&] {
    m.Lock();
    std::this_thread::sleep_for(100ms);
    m.Unlock();
    std::this_thread::sleep_for(100ms);
  };

  wheels::StopWatch stop_watch;

  fibers::Go(scheduler, task);
  fibers::Go(scheduler, task);
  fibers::Go(scheduler, task);
  fibers::Go(scheduler, task);

  scheduler.WaitIdle();

  std::cout << stop_watch.Elapsed().count() / 1e9 << std::endl; // 0.8

  scheduler.Stop();

  return 0;
}