librf/tutorial/test_async_when_all.cpp

#include <chrono>
#include <iostream>
#include <string>
#include <conio.h>
#include <thread>
#include <inttypes.h>

#include "librf.h"

using namespace resumef;

void test_when_any()
{
	using namespace std::chrono;

	GO
	{
		co_await when_any(
			[]() ->future_vt
			{
				auto dt = rand() % 1000;
				co_await sleep_for(1ms * dt);
				std::cout << dt << "@1000" << std::endl;
			}(),
			[]() ->future_vt
			{
				auto dt = rand() % 2000;
				co_await sleep_for(1ms * dt);
				std::cout << dt << "@2000" << std::endl;
			}(),
			[]() ->future_vt
			{
				auto dt = rand() % 3000;
				co_await sleep_for(1ms * dt);
				std::cout << dt << "@3000" << std::endl;
			}());
		std::cout << "any done!" << std::endl;
	};
	this_scheduler()->run_until_notask();
}

void test_when_all()
{
	using namespace std::chrono;

	auto my_sleep = [](const char * name) -> future_vt
	{
		auto dt = rand() % 1000;
		co_await sleep_for(1ms * dt);
		std::cout << dt << "@" << name << std::endl;
	};

	GO
	{
		co_await when_all();
		std::cout << "zero!" << std::endl << std::endl;

		co_await when_all(my_sleep("a"), my_sleep("b"));
		std::cout << std::endl;

		co_await my_sleep("c");
		std::cout << std::endl;

		co_await when_all(my_sleep("d"), my_sleep("e"), my_sleep("f"));
		std::cout << std::endl;

		std::vector<future_vt> v{ my_sleep("g"), my_sleep("h"), my_sleep("i") };
		co_await when_all(std::begin(v), std::end(v));
		std::cout << std::endl;

		std::cout << "all done!" << std::endl;
	};
	this_scheduler()->run_until_notask();
}

void resumable_main_when_all()
{
	srand((uint32_t)time(nullptr));

	test_when_any();
	std::cout << std::endl;
	test_when_all();
}