Version 0.1.2 (#46)

*  deprecation of await_via and resume_via
*  addition of lazy_result
*  addition of resume_on
*  when_all + when_any rewrite
*  shared_result optimizations
*  examples rewrite

Co-authored-by: Zakhar Karlin <zakhar.karlin11@gmail.com>

Author: David-Haim

CMakeLists.txt

@@ -1,7 +1,7 @@
 cmake_minimum_required(VERSION 3.16)
 
 project(concurrencpp
-        VERSION 0.1.1
+        VERSION 0.1.2
         LANGUAGES CXX)
 
 include(cmake/coroutineOptions.cmake)
@@ -52,15 +52,19 @@ set(concurrencpp_headers
         include/concurrencpp/results/impl/producer_context.h
         include/concurrencpp/results/impl/result_state.h
         include/concurrencpp/results/impl/shared_result_state.h
+        include/concurrencpp/results/impl/lazy_result_state.h
         include/concurrencpp/results/constants.h
         include/concurrencpp/results/make_result.h
         include/concurrencpp/results/promises.h
         include/concurrencpp/results/result.h
+        include/concurrencpp/results/lazy_result.h
+        include/concurrencpp/results/lazy_result_awaitable.h
         include/concurrencpp/results/shared_result.h
         include/concurrencpp/results/result_awaitable.h
         include/concurrencpp/results/shared_result_awaitable.h
         include/concurrencpp/results/result_fwd_declerations.h
         include/concurrencpp/results/when_result.h
+        include/concurrencpp/results/resume_on.h
         include/concurrencpp/runtime/constants.h
         include/concurrencpp/runtime/runtime.h
         include/concurrencpp/threads/thread.h

README.md

@@ -0,0 +1,17 @@
+cmake_minimum_required(VERSION 3.16)
+
+project(10_regular_timer LANGUAGES CXX)
+
+include(FetchContent)
+FetchContent_Declare(concurrencpp SOURCE_DIR "${CMAKE_CURRENT_LIST_DIR}/../..")
+FetchContent_MakeAvailable(concurrencpp)
+
+include(../../cmake/coroutineOptions.cmake)
+
+add_executable(10_regular_timer source/main.cpp)
+
+target_compile_features(10_regular_timer PRIVATE cxx_std_20)
+
+target_link_libraries(10_regular_timer PRIVATE concurrencpp::concurrencpp)
+
+target_coroutine_options(10_regular_timer)

example/10_regular_timer/CMakeLists.txt

@@ -0,0 +1,27 @@
+#include "concurrencpp/concurrencpp.h"
+
+#include <iostream>
+
+using namespace std::chrono_literals;
+
+int main() {
+    concurrencpp::runtime runtime;
+    std::atomic_size_t counter = 1;
+    concurrencpp::timer timer = runtime.timer_queue()->make_timer(1500ms, 2000ms, runtime.thread_pool_executor(), [&] {
+        const auto c = counter.fetch_add(1);
+        std::cout << "timer was invoked for the " << c << "th time" << std::endl;
+    });
+
+    std::cout << "timer due time (ms): " << timer.get_due_time().count() << std::endl;
+    std::cout << "timer frequency (ms): " << timer.get_frequency().count() << std::endl;
+    std::cout << "timer-associated executor : " << timer.get_executor()->name << std::endl;
+
+    std::this_thread::sleep_for(20s);
+
+    std::cout << "main thread cancelling timer" << std::endl;
+    timer.cancel();
+
+    std::this_thread::sleep_for(10s);
+
+    return 0;
+}

example/10_regular_timer/source/main.cpp

@@ -0,0 +1,17 @@
+cmake_minimum_required(VERSION 3.16)
+
+project(11_oneshot_time LANGUAGES CXX)
+
+include(FetchContent)
+FetchContent_Declare(concurrencpp SOURCE_DIR "${CMAKE_CURRENT_LIST_DIR}/../..")
+FetchContent_MakeAvailable(concurrencpp)
+
+include(../../cmake/coroutineOptions.cmake)
+
+add_executable(11_oneshot_time source/main.cpp)
+
+target_compile_features(11_oneshot_time PRIVATE cxx_std_20)
+
+target_link_libraries(11_oneshot_time PRIVATE concurrencpp::concurrencpp)
+
+target_coroutine_options(11_oneshot_time)

example/11_oneshot_timer/CMakeLists.txt

@@ -0,0 +1,19 @@
+#include "concurrencpp/concurrencpp.h"
+
+#include <iostream>
+
+using namespace std::chrono_literals;
+
+int main() {
+    concurrencpp::runtime runtime;
+    concurrencpp::timer timer = runtime.timer_queue()->make_one_shot_timer(3s, runtime.thread_executor(), [] {
+        std::cout << "hello and goodbye" << std::endl;
+    });
+
+    std::cout << "timer due time (ms): " << timer.get_due_time().count() << std::endl;
+    std::cout << "timer frequency (ms): " << timer.get_frequency().count() << std::endl;
+    std::cout << "timer-associated executor : " << timer.get_executor()->name << std::endl;
+
+    std::this_thread::sleep_for(4s);
+    return 0;
+}

example/11_oneshot_timer/source/main.cpp

@@ -0,0 +1,17 @@
+cmake_minimum_required(VERSION 3.16)
+
+project(12_delay_object LANGUAGES CXX)
+
+include(FetchContent)
+FetchContent_Declare(concurrencpp SOURCE_DIR "${CMAKE_CURRENT_LIST_DIR}/../..")
+FetchContent_MakeAvailable(concurrencpp)
+
+include(../../cmake/coroutineOptions.cmake)
+
+add_executable(12_delay_object source/main.cpp)
+
+target_compile_features(12_delay_object PRIVATE cxx_std_20)
+
+target_link_libraries(12_delay_object PRIVATE concurrencpp::concurrencpp)
+
+target_coroutine_options(12_delay_object)

example/12_delay_object/CMakeLists.txt

@@ -0,0 +1,25 @@
+#include <iostream>
+
+#include "concurrencpp/concurrencpp.h"
+
+using namespace std::chrono_literals;
+
+concurrencpp::null_result delayed_task(std::shared_ptr<concurrencpp::timer_queue> tq,
+                                       std::shared_ptr<concurrencpp::thread_pool_executor> ex) {
+    size_t counter = 1;
+
+    while (true) {
+        std::cout << "task was invoked " << counter << " times." << std::endl;
+        counter++;
+
+        co_await tq->make_delay_object(1500ms, ex);
+    }
+}
+
+int main() {
+    concurrencpp::runtime runtime;
+    delayed_task(runtime.timer_queue(), runtime.thread_pool_executor());
+
+    std::this_thread::sleep_for(10s);
+    return 0;
+}

example/12_delay_object/source/main.cpp

@@ -0,0 +1,17 @@
+cmake_minimum_required(VERSION 3.16)
+
+project(1_hello_world LANGUAGES CXX)
+
+include(FetchContent)
+FetchContent_Declare(concurrencpp SOURCE_DIR "${CMAKE_CURRENT_LIST_DIR}/../..")
+FetchContent_MakeAvailable(concurrencpp)
+
+include(../../cmake/coroutineOptions.cmake)
+
+add_executable(1_hello_world source/main.cpp)
+
+target_compile_features(1_hello_world PRIVATE cxx_std_20)
+
+target_link_libraries(1_hello_world PRIVATE concurrencpp::concurrencpp)
+
+target_coroutine_options(1_hello_world)

example/1_hello_world/CMakeLists.txt

@@ -0,0 +1,12 @@
+#include "concurrencpp/concurrencpp.h"
+#include <iostream>
+
+int main() {
+    concurrencpp::runtime runtime;
+    auto result = runtime.thread_executor()->submit([] {
+        std::cout << "hello world" << std::endl;
+    });
+
+    result.get();
+    return 0;
+}