xbmc/platform/win10/AsyncHelpers.h

   1 /*
   2  *  Copyright (C) 2005-2018 Team Kodi
   3  *  This file is part of Kodi - https://kodi.tv
   4  *
   5  *  SPDX-License-Identifier: GPL-2.0-or-later
   6  *  See LICENSES/README.md for more information.
   7  */
   8
   9 #pragma once
  10
  11 #include <ppl.h>
  12 #include <ppltasks.h>
  13 #include <sdkddkver.h>
  14
  15 #ifndef TARGET_WINDOWS_STORE
  16 #include <winrt/windows.foundation.h>
  17 #endif
  18
  19 namespace winrt
  20 {
  21   using namespace Windows::Foundation;
  22 }
  23
  24 inline bool is_sta()
  25 {
  26 #ifdef NTDDI_WIN10_CO // Windows SDK 10.0.22000.0 or newer
  27   return winrt::impl::is_sta_thread();
  28 #else
  29   return winrt::impl::is_sta();
  30 #endif
  31 }
  32
  33 inline void Wait(const winrt::IAsyncAction& asyncOp)
  34 {
  35   if (asyncOp.Status() == winrt::AsyncStatus::Completed)
  36     return;
  37
  38   if (!is_sta())
  39     return asyncOp.get();
  40
  41   auto __sync = std::make_shared<Concurrency::event>();
  42   asyncOp.Completed([&](auto&&, auto&&) {
  43     __sync->set();
  44   });
  45   __sync->wait();
  46 }
  47
  48 template <typename TResult, typename TProgress> inline
  49 TResult Wait(const winrt::IAsyncOperationWithProgress<TResult, TProgress>& asyncOp)
  50 {
  51   if (asyncOp.Status() == winrt::AsyncStatus::Completed)
  52     return asyncOp.GetResults();
  53
  54   if (!is_sta())
  55     return asyncOp.get();
  56
  57   auto __sync = std::make_shared<Concurrency::event>();
  58   asyncOp.Completed([&](auto&&, auto&&) {
  59     __sync->set();
  60   });
  61   __sync->wait();
  62
  63   return asyncOp.GetResults();
  64 }
  65
  66 template <typename TResult> inline
  67 TResult Wait(const winrt::IAsyncOperation<TResult>& asyncOp)
  68 {
  69   if (asyncOp.Status() == winrt::AsyncStatus::Completed)
  70     return asyncOp.GetResults();
  71
  72   if (!is_sta())
  73     return asyncOp.get();
  74
  75   auto __sync = std::make_shared<Concurrency::event>();
  76   asyncOp.Completed([&](auto&&, auto&&)
  77   {
  78     __sync->set();
  79   });
  80   __sync->wait();
  81
  82   return asyncOp.GetResults();
  83 }
  84
  85 template <typename TResult> inline
  86 TResult Wait(const Concurrency::task<TResult>& asyncOp)
  87 {
  88   if (asyncOp.is_done())
  89     return asyncOp.get();
  90
  91   if (!is_sta()) // blocking suspend is allowed
  92     return asyncOp.get();
  93
  94   auto _sync = std::make_shared<Concurrency::event>();
  95   asyncOp.then([&](TResult result)
  96   {
  97     _sync->set();
  98   });
  99   _sync->wait();
 100
 101   return asyncOp.get();
 102 }