Fea， 添加WhenAny、WhenAll协程

Author: mingkuang-Chuyu

include/YY/Base/IO/File.h

@@ -62,7 +62,7 @@ namespace YY
                 private:
                     CoroutineReadWriteTask(bool)
                     {
-                        hCoroutineHandle = -1;
+                        oCoroutineInfo.hCoroutineHandle = -1;
                         lStatus = ERROR_OUTOFMEMORY;
                     }
 
@@ -71,13 +71,7 @@ namespace YY
 
                     HRESULT __YYAPI RunTask() override
                     {
-                        auto _hHandle = (void*)YY::Base::Sync::Exchange(&hCoroutineHandle, /*hReadyHandle*/ (intptr_t)-1);
-                        if (_hHandle)
-                        {
-                            std::coroutine_handle<>::from_address(_hHandle).resume();
-                        }
-
-                        return S_OK;
+                        return Resume();
                     }
 
                     uint32_t __YYAPI AddRef() noexcept override
@@ -90,7 +84,7 @@ namespace YY
                         return IoTaskEntry::Release();
                     }
 
-                    uint32_t __YYAPI Resume() noexcept override
+                    uint32_t __YYAPI GetResult() noexcept override
                     {
                         SetLastError(lStatus);
                         return uint32_t(InternalHigh);
@@ -263,7 +257,7 @@ namespace YY
                         if (_lStatus != ERROR_SUCCESS)
                         {
                             // 失败时，异步任务不会在触发了。也算是一种任务完成。
-                            _pAsyncTaskEntry->hCoroutineHandle = -1;
+                            _pAsyncTaskEntry->Resume();
                         }
                     }
                     else
@@ -297,7 +291,7 @@ namespace YY
                         if (_lStatus != ERROR_SUCCESS)
                         {
                             // 失败时，异步任务不会在触发了。也算是一种任务完成。
-                            _pAsyncTaskEntry->hCoroutineHandle = -1;
+                            _pAsyncTaskEntry->Resume();
                         }
                     }
                     else
@@ -513,7 +507,7 @@ namespace YY
                     private:
                         CoroutineConnectTask(bool)
                         {
-                            hCoroutineHandle = -1;
+                            oCoroutineInfo.hCoroutineHandle = -1;
                             lStatus = ERROR_OUTOFMEMORY;
                         }
 
@@ -522,13 +516,7 @@ namespace YY
 
                         HRESULT __YYAPI RunTask() override
                         {
-                            auto _hHandle = (void*)YY::Base::Sync::Exchange(&hCoroutineHandle, /*hReadyHandle*/ (intptr_t)-1);
-                            if (_hHandle)
-                            {
-                                std::coroutine_handle<>::from_address(_hHandle).resume();
-                            }
-
-                            return S_OK;
+                            return Resume();
                         }
 
                         uint32_t __YYAPI AddRef() noexcept override
@@ -541,7 +529,7 @@ namespace YY
                             return IoTaskEntry::Release();
                         }
 
-                        LSTATUS __YYAPI Resume() noexcept override
+                        LSTATUS __YYAPI GetResult() noexcept override
                         {
                             return lStatus;
                         }
@@ -559,7 +547,7 @@ namespace YY
                         auto _lStatus = AsyncConnectIntetnal(_pConnectTask);
                         if (_lStatus != ERROR_SUCCESS)
                         {
-                            _pConnectTask->hCoroutineHandle = -1;
+                            _pConnectTask->Resume();
                         }
                     }
                     else

include/YY/Base/Sync/Interlocked.h

@@ -408,6 +408,29 @@ namespace YY
                 return (Type1*)CompareExchange(reinterpret_cast<intptr_t*>(_ppDestination), reinterpret_cast<intptr_t>(static_cast<Type1*>(_pExchange)), reinterpret_cast<intptr_t>(static_cast<Type1*>(_pComparand)));
             }
 
+            /// <summary>
+            ///  直接交换2个指针的值
+            /// </summary>
+            /// <typeparam name="Type"></typeparam>
+            /// <param name="_pDestinationPoints"></param>
+            /// <param name="_pExchangePoints"></param>
+            /// <param name="_pComparandResult"></param>
+            /// <returns></returns>
+            inline bool __YYAPI CompareExchangeTwoPoints(_Inout_updates_(2) volatile intptr_t* _pDestinationPoints, _In_reads_(2) const intptr_t* _pExchangePoints, _Inout_updates_(2) intptr_t* _pComparandResult)
+            {
+#if defined(_X86_) || defined(_ARM_)
+                static_assert(sizeof(intptr_t) * 2 == sizeof(int64_t), "");
+                auto _iComparand = *reinterpret_cast<int64_t*>(_pComparandResult);
+
+                auto _iPreValue = CompareExchange(reinterpret_cast<volatile int64_t*>(_pDestinationPoints), *reinterpret_cast<const int64_t*>(_pExchangePoints), _iComparand);
+                *reinterpret_cast<int64_t*>(_pComparandResult) = _iPreValue;
+                return _iPreValue == _iComparand;
+#else
+                static_assert(sizeof(intptr_t) == sizeof(LONG64), "");
+                return InterlockedCompareExchange128(reinterpret_cast<volatile LONG64*>(_pDestinationPoints), reinterpret_cast<const LONG64*>(_pExchangePoints)[1], reinterpret_cast<const LONG64*>(_pExchangePoints)[0], reinterpret_cast<LONG64*>(_pComparandResult));
+#endif
+            }
+
             inline int32_t __YYAPI Exchange(volatile int32_t* _pDestination, int32_t _iExchange)
             {
 #ifdef _MSC_VER