Version 0.1.0 (#39)

Author: David-Haim

CMakeLists.txt

@@ -1,7 +1,7 @@
 cmake_minimum_required(VERSION 3.16)
 
 project(concurrencpp
-        VERSION 0.0.9
+        VERSION 0.1.0
         LANGUAGES CXX)
 
 include(cmake/coroutineOptions.cmake)
@@ -25,6 +25,7 @@ set(concurrencpp_sources
         source/executors/worker_thread_executor.cpp
         source/results/impl/consumer_context.cpp
         source/results/impl/result_state.cpp
+        source/results/impl/shared_result_state.cpp
         source/results/promises.cpp
         source/runtime/runtime.cpp
         source/threads/thread.cpp
@@ -50,11 +51,14 @@ set(concurrencpp_headers
         include/concurrencpp/results/impl/consumer_context.h
         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/constants.h
         include/concurrencpp/results/make_result.h
         include/concurrencpp/results/promises.h
         include/concurrencpp/results/result.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/runtime/constants.h

README.md

@@ -4,6 +4,7 @@ macro(add_library TARGET)
   _add_library(${ARGV})
 
   if("${TARGET}" STREQUAL "concurrencpp")
-    target_compile_options(concurrencpp PRIVATE -fsanitize=thread)
+    target_compile_options(concurrencpp PUBLIC -fsanitize=thread)
+    target_link_options(concurrencpp PUBLIC -fsanitize=thread)
   endif()
 endmacro()

cmake/concurrencppInjectTSAN.cmake

@@ -10,6 +10,8 @@
 #include "concurrencpp/results/result.h"
 #include "concurrencpp/results/make_result.h"
 #include "concurrencpp/results/when_result.h"
+#include "concurrencpp/results/shared_result.h"
+#include "concurrencpp/results/shared_result_awaitable.h"
 #include "concurrencpp/executors/executor_all.h"
 
 #endif

include/concurrencpp/concurrencpp.h

@@ -3,6 +3,7 @@
 
 #include "concurrencpp/task.h"
 #include "concurrencpp/results/result.h"
+#include "concurrencpp/results/promises.h"
 
 #include <span>
 #include <vector>

include/concurrencpp/executors/executor.h

@@ -11,11 +11,9 @@ namespace concurrencpp {
         std::atomic_bool m_abort;
 
         void throw_if_aborted() const {
-            if (!m_abort.load(std::memory_order_relaxed)) {
-                return;
+            if (m_abort.load(std::memory_order_relaxed)) {
+                details::throw_executor_shutdown_exception(name);
             }
-
-            details::throw_executor_shutdown_exception(name);
         }
 
        public:

include/concurrencpp/executors/inline_executor.h

@@ -50,7 +50,6 @@ namespace concurrencpp {
         size_t clear();
 
         bool loop_once();
-
         bool loop_once_for(std::chrono::milliseconds max_waiting_time);
 
         template<class clock_type, class duration_type>
@@ -59,7 +58,6 @@ namespace concurrencpp {
         }
 
         size_t loop(size_t max_count);
-
         size_t loop_for(size_t max_count, std::chrono::milliseconds max_waiting_time);
 
         template<class clock_type, class duration_type>
@@ -68,7 +66,6 @@ namespace concurrencpp {
         }
 
         void wait_for_task();
-
         bool wait_for_task_for(std::chrono::milliseconds max_waiting_time);
 
         template<class clock_type, class duration_type>
@@ -77,7 +74,6 @@ namespace concurrencpp {
         }
 
         void wait_for_tasks(size_t count);
-
         size_t wait_for_tasks_for(size_t count, std::chrono::milliseconds max_waiting_time);
 
         template<class clock_type, class duration_type>

include/concurrencpp/executors/manual_executor.h

@@ -1,8 +1,8 @@
 #ifndef CONCURRENCPP_THREAD_EXECUTOR_H
 #define CONCURRENCPP_THREAD_EXECUTOR_H
 
-#include "concurrencpp/executors/derivable_executor.h"
 #include "concurrencpp/threads/thread.h"
+#include "concurrencpp/executors/derivable_executor.h"
 
 #include <list>
 #include <span>

include/concurrencpp/executors/thread_executor.h

@@ -6,7 +6,7 @@
 #elif defined(unix) || defined(__unix__) || defined(__unix)
 #    define CRCPP_UNIX_OS
 #elif defined(__APPLE__) || defined(__MACH__)
-#    define CRCPP_MACH_OS
+#    define CRCPP_MAC_OS
 #elif defined(__FreeBSD__)
 #    define CRCPP_FREE_BSD_OS
 #elif defined(__ANDROID__)

include/concurrencpp/platform_defs.h

@@ -48,6 +48,28 @@ namespace concurrencpp::details::consts {
 
     inline const char* k_broken_task_exception_error_msg = "concurrencpp::result - Associated task was interrupted abnormally";
 
+    inline const char* k_shared_result_status_error_msg = "shared_result::status() - result is empty.";
+
+    inline const char* k_shared_result_get_error_msg = "shared_result::get() - result is empty.";
+
+    inline const char* k_shared_result_wait_error_msg = "shared_result::wait() - result is empty.";
+
+    inline const char* k_shared_result_wait_for_error_msg = "shared_result::wait_for() - result is empty.";
+
+    inline const char* k_shared_result_wait_until_error_msg = "shared_result::wait_until() - result is empty.";
+
+    inline const char* k_shared_result_operator_co_await_error_msg = "shared_result::operator co_await() - result is empty.";
+
+    inline const char* k_shared_result_await_via_error_msg = "shared_result::await_via() - result is empty.";
+
+    inline const char* k_shared_result_await_via_executor_null_error_msg = "shared_result::await_via() - given executor is null.";
+
+    inline const char* k_shared_result_resolve_error_msg = "shared_result::resolve() - result is empty.";
+
+    inline const char* k_shared_result_resolve_via_error_msg = "shared_result::resolve_via() - result is empty.";
+
+    inline const char* k_shared_result_resolve_via_executor_null_error_msg = "shared_result::resolve_via() - given executor is null.";
+
 }  // namespace concurrencpp::details::consts
 
 #endif