Core - Add Cef.PostAction and Cef.PostDelayedAction

Author: amaitland

CefSharp.Core.Runtime.RefAssembly/CefSharp.Core.Runtime.netcore.cs

@@ -81,6 +81,8 @@ public static void EnableWaitForBrowsersToClose() { }
         public static bool Initialize(CefSharp.Core.CefSettingsBase cefSettings, bool performDependencyCheck, CefSharp.IApp cefApp) { throw null; }
         public static bool Initialize(CefSharp.Core.CefSettingsBase cefSettings, bool performDependencyCheck, CefSharp.IBrowserProcessHandler browserProcessHandler) { throw null; }
         public static CefSharp.UrlParts ParseUrl(string url) { throw null; }
+        public static bool PostAction(CefSharp.CefThreadIds threadId, System.Action action) { throw null; }
+        public static bool PostDelayedAction(CefSharp.CefThreadIds threadId, System.Action action, int delayInMs) { throw null; }
         public static void PreShutdown() { }
         public static void QuitMessageLoop() { }
         public static bool RemoveCrossOriginWhitelistEntry(string sourceOrigin, string targetProtocol, string targetDomain, bool allowTargetSubdomains) { throw null; }

CefSharp.Core.Runtime/Cef.h

@@ -15,10 +15,12 @@
 #include <include/cef_origin_whitelist.h>
 #include <include/cef_crash_util.h>
 #include <include/cef_parser.h>
+#include <include/cef_task.h>
 #include <include/internal/cef_types.h>
 
 #include "Internals/CefSharpApp.h"
 #include "Internals/CefTaskScheduler.h"
+#include "Internals/CefTaskDelegate.h"
 #include "CookieManager.h"
 #include "CefSettingsBase.h"
 #include "RequestContext.h"
@@ -883,6 +885,33 @@ namespace CefSharp
                 //A few extra ms to allow for CEF to finish 
                 Thread::Sleep(50);
             }
+
+            /// <summary>
+            /// Post an action for delayed execution on the specified thread.
+            /// </summary>
+            /// <param name="threadId">thread id</param>
+            /// <param name="action">action to execute</param>
+            /// <param name="delayInMs">delay in ms</param>
+            /// <returns>bool</returns>
+            static bool PostDelayedAction(CefThreadIds threadId, Action^ action, int delayInMs)
+            {
+                auto task = new CefTaskDelegate(action);
+
+                return CefPostDelayedTask((cef_thread_id_t)threadId, task, delayInMs);
+            }
+
+            /// <summary>
+            /// Post an action for execution on the specified thread.
+            /// </summary>
+            /// <param name="threadId">thread id</param>
+            /// <param name="action">action to execute</param>
+            /// <returns>bool</returns>
+            static bool PostAction(CefThreadIds threadId, Action^ action)
+            {
+                auto task = new CefTaskDelegate(action);
+
+                return CefPostTask((cef_thread_id_t)threadId, task);
+            }
         };
     }
 }

CefSharp.Core.Runtime/CefSharp.Core.Runtime.netcore.vcxproj

@@ -373,6 +373,7 @@
     <ClInclude Include="Internals\CefResourceSkipCallbackWrapper.h" />
     <ClInclude Include="Internals\CefRunFileDialogCallbackAdapter.h" />
     <ClInclude Include="Internals\CefSchemeRegistrarWrapper.h" />
+    <ClInclude Include="Internals\CefTaskDelegate.h" />
     <ClInclude Include="Internals\CefUrlRequestClientAdapter.h" />
     <ClInclude Include="Internals\CefValueWrapper.h" />
     <ClInclude Include="Internals\CefWriteHandlerWrapper.h" />

CefSharp.Core.Runtime/CefSharp.Core.Runtime.netcore.vcxproj.filters

@@ -328,6 +328,9 @@
     <ClInclude Include="Internals\CefRefCountManaged.h">
       <Filter>Header Files</Filter>
     </ClInclude>
+    <ClInclude Include="Internals\CefTaskDelegate.h">
+      <Filter>Header Files</Filter>
+    </ClInclude>
   </ItemGroup>
   <ItemGroup>
     <ClInclude Include="Internals\CefFrameWrapper.h">

CefSharp.Core.Runtime/CefSharp.Core.Runtime.vcxproj

@@ -278,6 +278,7 @@
     <ClInclude Include="Internals\CefResourceSkipCallbackWrapper.h" />
     <ClInclude Include="Internals\CefRunFileDialogCallbackAdapter.h" />
     <ClInclude Include="Internals\CefSchemeRegistrarWrapper.h" />
+    <ClInclude Include="Internals\CefTaskDelegate.h" />
     <ClInclude Include="Internals\CefUrlRequestClientAdapter.h" />
     <ClInclude Include="Internals\CefValueWrapper.h" />
     <ClInclude Include="Internals\CefWriteHandlerWrapper.h" />

CefSharp.Core.Runtime/CefSharp.Core.Runtime.vcxproj.filters

@@ -328,6 +328,9 @@
     <ClInclude Include="Internals\CefRefCountManaged.h">
       <Filter>Header Files</Filter>
     </ClInclude>
+    <ClInclude Include="Internals\CefTaskDelegate.h">
+      <Filter>Header Files</Filter>
+    </ClInclude>
   </ItemGroup>
   <ItemGroup>
     <ClInclude Include="Internals\CefFrameWrapper.h">

CefSharp.Core.Runtime/Internals/CefTaskDelegate.h

@@ -0,0 +1,42 @@
+// Copyright © 2022 The CefSharp Authors. All rights reserved.
+//
+// Use of this source code is governed by a BSD-style license that can be found in the LICENSE file.
+
+#pragma once
+
+#include "Stdafx.h"
+#include "include/cef_task.h"
+
+#include "ReportUnhandledExceptions.h"
+
+namespace CefSharp
+{
+    namespace Internals
+    {
+        private class CefTaskDelegate : public CefTask
+        {
+        private:
+            gcroot<Action^> _action;
+        public:
+            CefTaskDelegate(Action^ action) :
+                _action(action)
+            {
+            };
+
+            virtual void Execute() override
+            {
+                try
+                {
+                    _action->Invoke();
+                }
+                catch (Exception^ e)
+                {
+                    auto msg = gcnew String(L"CefTaskDelegate caught an unexpected exception. This exception has been redirected onto the ThreadPool, add a try catch.");
+                    ReportUnhandledExceptions::Report(msg, e);
+                }
+            };
+
+            IMPLEMENT_REFCOUNTINGM(CefTaskDelegate);
+        };
+    }
+}

CefSharp.Core/Cef.cs

@@ -644,5 +644,28 @@ public static void WaitForBrowsersToClose(int timeoutInMiliseconds)
         {
             Core.Cef.WaitForBrowsersToClose(timeoutInMiliseconds);
         }
+
+        /// <summary>
+        /// Post an action for delayed execution on the specified thread.
+        /// </summary>
+        /// <param name="threadId">thread id</param>
+        /// <param name="action">action to execute</param>
+        /// <param name="delayInMs">delay in ms</param>
+        /// <returns>bool</returns>
+        public static bool PostDelayedAction(CefThreadIds threadId, Action action, int delayInMs)
+        {
+            return Core.Cef.PostDelayedAction(threadId, action, delayInMs);
+        }
+
+        /// <summary>
+        /// Post an action for execution on the specified thread.
+        /// </summary>
+        /// <param name="threadId">thread id</param>
+        /// <param name="action">action to execute</param>
+        /// <returns>bool</returns>
+        public static bool PostAction(CefThreadIds threadId, Action action)
+        {
+            return Core.Cef.PostAction(threadId, action);
+        }
     }
 }