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
  14 namespace winrt
  15 {
  16   using namespace Windows::Foundation;
  17 }
  18
  19 inline void Wait(const winrt::IAsyncAction& asyncOp)
  20 {
  21   if (asyncOp.Status() == winrt::AsyncStatus::Completed)
  22     return;
  23
  24   if (!winrt::impl::is_sta())
  25     return asyncOp.get();
  26
  27   auto __sync = std::make_shared<Concurrency::event>();
  28   asyncOp.Completed([&](auto&&, auto&&) {
  29     __sync->set();
  30   });
  31   __sync->wait();
  32 }
  33
  34 template <typename TResult, typename TProgress> inline
  35 TResult Wait(const winrt::IAsyncOperationWithProgress<TResult, TProgress>& asyncOp)
  36 {
  37   if (asyncOp.Status() == winrt::AsyncStatus::Completed)
  38     return asyncOp.GetResults();
  39
  40   if (!winrt::impl::is_sta())
  41     return asyncOp.get();
  42
  43   auto __sync = std::make_shared<Concurrency::event>();
  44   asyncOp.Completed([&](auto&&, auto&&) {
  45     __sync->set();
  46   });
  47   __sync->wait();
  48
  49   return asyncOp.GetResults();
  50 }
  51
  52 template <typename TResult> inline
  53 TResult Wait(const winrt::IAsyncOperation<TResult>& asyncOp)
  54 {
  55   if (asyncOp.Status() == winrt::AsyncStatus::Completed)
  56     return asyncOp.GetResults();
  57
  58   if (!winrt::impl::is_sta())
  59     return asyncOp.get();
  60
  61   auto __sync = std::make_shared<Concurrency::event>();
  62   asyncOp.Completed([&](auto&&, auto&&)
  63   {
  64     __sync->set();
  65   });
  66   __sync->wait();
  67
  68   return asyncOp.GetResults();
  69 }
  70
  71 template <typename TResult> inline
  72 TResult Wait(const Concurrency::task<TResult>& asyncOp)
  73 {
  74   if (asyncOp.is_done())
  75     return asyncOp.get();
  76
  77   if (!winrt::impl::is_sta()) // blocking suspend is allowed
  78     return asyncOp.get();
  79
  80   auto _sync = std::make_shared<Concurrency::event>();
  81   asyncOp.then([&](TResult result)
  82   {
  83     _sync->set();
  84   });
  85   _sync->wait();
  86
  87   return asyncOp.get();
  88 }