xtd 0.2.0
__delegate.hpp
Go to the documentation of this file.
1
4#pragma once
6#if !defined(__XTD_CORE_INTERNAL__)
7#error "Do not include this file: Internal use only"
8#endif
10
11#include "../threading/manual_reset_event.hpp"
12#include "../delegate.hpp"
13
15template<class result_t = void>
16inline result_t __xtd_delegate_any_cast(const xtd::any_object& value) {
17 return value.has_value() ? xtd::as<result_t>(value) : result_t {};
18}
19
20template<>
21inline void __xtd_delegate_any_cast<void>(const xtd::any_object& value) {
22 return;
23}
24
25inline xtd::any_object __xtd_delegate_invoker(std::function<void()> invoke) {
26 invoke();
27 return xtd::any_object {};
28}
29
30template<class ...arguments_t>
31inline xtd::any_object __xtd_delegate_invoker(std::function<void(arguments_t...)> invoke, arguments_t&&... arguments) {
32 invoke(std::forward<arguments_t>(arguments)...);
33 return xtd::any_object {};
34}
35
36template<class result_t>
37inline xtd::any_object __xtd_delegate_invoker(std::function<result_t()> invoke) {
38 return xtd::any_object(invoke());
39}
40
41template<class result_t, class ...arguments_t>
42inline xtd::any_object __xtd_delegate_invoker(std::function<result_t(arguments_t...)> invoke, arguments_t&&... arguments) {
43 return xtd::any_object(invoke(std::forward<arguments_t>(arguments)...));
44}
45
46template<class result_t>
47struct xtd::delegate<result_t()>::async_result_invoke::data {
48 xtd::async_callback async_callback;
49 xtd::threading::manual_reset_event async_event;
50 xtd::any_object async_state;
51 bool is_completed = false;
52 xtd::any_object result;
53};
54
55template<class result_t>
56xtd::delegate<result_t()>::async_result_invoke::async_result_invoke(xtd::async_callback async_callback, const xtd::any_object& async_state) : data_(xtd::new_sptr<data>()) {
57 data_->async_callback = async_callback;
58 data_->async_state = async_state;
59}
60
61template<class result_t>
62xtd::any_object xtd::delegate<result_t()>::async_result_invoke::async_state() const noexcept {
63 return data_->async_state;
64}
65
66template<class result_t>
67xtd::threading::wait_handle& xtd::delegate<result_t()>::async_result_invoke::async_wait_handle() noexcept {
68 return data_->async_event;
69}
70
71template<class result_t>
72bool xtd::delegate<result_t()>::async_result_invoke::completed_synchronously() const noexcept {
73 return false;
74}
75
76template<class result_t>
77bool xtd::delegate<result_t()>::async_result_invoke::is_completed() const noexcept {
78 return data_->is_completed;
79}
80
81template<class result_t>
82inline xtd::async_result xtd::delegate<result_t()>::begin_invoke() {
83 return begin_invoke(xtd::async_callback {}, xtd::any_object(*this));
84}
85
86template<class result_t>
87inline xtd::async_result xtd::delegate<result_t()>::begin_invoke(xtd::async_callback async_callback) {
88 return begin_invoke(async_callback, xtd::any_object(*this));
89}
90
91template<class result_t>
92xtd::async_result xtd::delegate<result_t()>::begin_invoke(xtd::async_callback async_callback, const xtd::any_object& async_state) {
93 auto async = xtd::new_sptr<async_result_invoke>(async_callback, async_state);
94 threading::thread_pool::queue_user_work_item([&, async = async] {
95 async->data_->result = __xtd_delegate_invoker(function_t {std::bind(&xtd::delegate<result_t()>::invoke, this)});
96 async->data_->is_completed = true;
97 async->data_->async_event.set();
98 async->data_->async_callback(async);
99 });
100 return async;
101}
102
103template<class result_t>
104result_t xtd::delegate<result_t()>::end_invoke(async_result async) {
105 auto async_result = as<async_result_invoke>(async);
106 async_result->data_->async_event.wait_one();
107 return __xtd_delegate_any_cast<result_t>(async_result->data_->result);
108}
109
110template<class result_t, class ...arguments_t>
111struct xtd::delegate<result_t(arguments_t...)>::async_result_invoke::data {
112 xtd::async_callback async_callback;
113 xtd::threading::manual_reset_event async_event;
114 xtd::any_object async_state;
115 bool is_completed = false;
116 xtd::any_object result;
117};
118
119template<class result_t, class ...arguments_t>
120xtd::delegate<result_t(arguments_t...)>::async_result_invoke::async_result_invoke(xtd::async_callback async_callback, const xtd::any_object& async_state) : data_(xtd::new_sptr<data>()) {
121 data_->async_callback = async_callback;
122 data_->async_state = async_state;
123}
124
125template<class result_t, class ...arguments_t>
126xtd::any_object xtd::delegate<result_t(arguments_t...)>::async_result_invoke::async_state() const noexcept {
127 return data_->async_state;
128}
129
130template<class result_t, class ...arguments_t>
131xtd::threading::wait_handle& xtd::delegate<result_t(arguments_t...)>::async_result_invoke::async_wait_handle() noexcept {
132 return data_->async_event;
133}
134
135template<class result_t, class ...arguments_t>
136bool xtd::delegate<result_t(arguments_t...)>::async_result_invoke::completed_synchronously() const noexcept {
137 return false;
138}
139
140template<class result_t, class ...arguments_t>
141bool xtd::delegate<result_t(arguments_t...)>::async_result_invoke::is_completed() const noexcept {
142 return data_->is_completed;
143}
144
145template<class result_t, class ...arguments_t>
146xtd::async_result xtd::delegate<result_t(arguments_t...)>::begin_invoke(arguments_t&&... arguments) {
147 return begin_invoke(xtd::async_callback {}, xtd::any_object(*this), std::forward<arguments_t>(arguments)...);
148}
149
150template<class result_t, class ...arguments_t>
151xtd::async_result xtd::delegate<result_t(arguments_t...)>::begin_invoke(xtd::async_callback async_callback, arguments_t&&... arguments) {
152 return begin_invoke(async_callback, xtd::any_object(*this), std::forward<arguments_t>(arguments)...);
153}
154
155template<class result_t, class ...arguments_t>
156xtd::async_result xtd::delegate<result_t(arguments_t...)>::begin_invoke(xtd::async_callback async_callback, const xtd::any_object& async_state, arguments_t&&... arguments) {
157 auto async = xtd::new_sptr<async_result_invoke>(async_callback, async_state);
158 threading::thread_pool::queue_user_work_item([&, async = async, ...arguments = arguments] {
159 async->data_->result = __xtd_delegate_invoker(function_t {std::bind(&xtd::delegate<result_t(arguments_t...)>::invoke, this, arguments...)}, std::forward<arguments_t>(arguments)...);
160 async->data_->is_completed = true;
161 async->data_->async_event.set();
162 async->data_->async_callback(async);
163 });
164 return async;
165}
166
167template<class result_t, class ...arguments_t>
168result_t xtd::delegate<result_t(arguments_t...)>::end_invoke(async_result async) {
169 auto async_result = as<async_result_invoke>(async);
170 if (!async_result->data_->is_completed) async_result->data_->async_event.wait_one();
171 return __xtd_delegate_any_cast<result_t>(async_result->data_->result);
172}
xtd::any_object
Represent a polymorphic wrapper capable of holding any type.
Definition any_object.hpp:29
xtd::any_object::has_value
bool has_value() const noexcept
Gets a value indicating whether the current xtd::any_object object has a valid value of its underlyin...
Definition any_object.hpp:62
xtd::shared_ptr_object
The xtd::shared_ptr_object is a shared pointer as std::shared_ptr.
Definition shared_ptr_object.hpp:30
xtd::threading::manual_reset_event
Represents a thread synchronization event that, when signaled, must be reset manually....
Definition manual_reset_event.hpp:35
xtd::threading::wait_handle
Encapsulates operating system specific objects that wait for exclusive access to shared resources.
Definition wait_handle.hpp:52
xtd::async_callback
xtd::delegate< void(async_result ar)> async_callback
References a method to be called when a corresponding asynchronous operation completes.
Definition delegate.hpp:39
xtd::async_result
xtd::sptr< xtd::iasync_result > async_result
Represents the status of an asynchronous operation.
Definition async_result.hpp:19
xtd::new_sptr
sptr< type_t > new_sptr(args_t &&... args)
xtd::new_sptr operator creates a xtd::sptr object.
Definition new_sptr.hpp:24
xtd
The xtd namespace contains all fundamental classes to access Hardware, Os, System,...
Definition xtd_about_box.hpp:10
Generated on Thu Apr 17 2025 11:16:27 for xtd by Gammasoft. All rights reserved.