feat: add dedicated JavaScript thread support

README.md

@@ -3,13 +3,13 @@
 WebF presents a high-performance, cutting-edge web rendering engine built on top of Flutter, empowering web applications to operate natively within the Flutter ecosystem.
 
 - **Adherence to W3C Standards:** By leveraging HTML/CSS and JavaScript, WebF renders content on Flutter, ensuring impeccable alignment with standard browser rendering.
-  
+
 - **Compatible with Leading Front-End Frameworks:** Given its compliance with W3C standards, WebF seamlessly integrates with popular front-end frameworks, including [React](https://reactjs.org/) and [Vue](https://vuejs.org/).
-  
+
 - **Amplify Your Web Applications with Flutter:** WebF's adaptability shines through its customization capabilities. Craft bespoke HTML elements using Flutter Widgets or enhance your application by integrating a JavaScript API sourced from any Dart library on the `pub.dev` registry.
-  
+
 - **Authentic Web Development Environment:** Experience a traditional web development setting with WebF. It facilitates DOM structure inspection, CSS style evaluations, and JavaScript debugging via Chrome DevTools.
-  
+
 - **Craft Once, Deploy Everywhere:** Harness the versatility of WebF to design your web application and launch it across any Flutter-compatible device. What's more, maintain the flexibility to execute your apps within Node.js or web browsers, all from a unified codebase.
 
 ## Join Our Mission
@@ -26,7 +26,7 @@ If you or your team are interested in supporting us, please contact @andycall on
 
 [![Discord Shield](https://discordapp.com/api/guilds/1008119434688344134/widget.png?style=banner1)](https://discord.gg/DvUBtXZ5rK)
 
-## The update and maintenance policy for WebF versions 
+## The update and maintenance policy for WebF versions
 
 Each version of WebF will be maintained for the lifespan of three minor WebF releases. For instance, WebF 0.15.0 was released to be compatible with Flutter 3.10.x. Its support will conclude once WebF 0.18.0 is introduced. Any updates applied to versions 0.16.x and 0.17.x will be cherry-picked for the subsequent update of 0.15.x.
 

bridge/CMakeLists.txt

@@ -38,6 +38,12 @@ else ()
   add_definitions(-DENABLE_PROFILE=0)
 endif ()
 
+if (${ENABLE_LOG})
+  add_definitions(-DENABLE_LOG=1)
+else()
+  add_definitions(-DENABLE_LOG=0)
+endif()
+
 if(NOT MSVC)
   if (${CMAKE_BUILD_TYPE} STREQUAL "Release" OR ${CMAKE_BUILD_TYPE} STREQUAL "RelWithDebInfo")
     include(CheckIPOSupported)
@@ -91,17 +97,19 @@ if (DEFINED PLATFORM)
 endif()
 
 list(APPEND BRIDGE_SOURCE
-  webf_bridge.cc
   foundation/logging.cc
   foundation/native_string.cc
   foundation/ui_task_queue.cc
+  foundation/shared_ui_command.cc
   foundation/inspector_task_queue.cc
   foundation/task_queue.cc
   foundation/string_view.cc
   foundation/native_value.cc
   foundation/native_type.cc
   foundation/ui_command_buffer.cc
   polyfill/dist/polyfill.cc
+  multiple_threading/dispatcher.cc
+  multiple_threading/looper.cc
   ${CMAKE_CURRENT_LIST_DIR}/third_party/dart/include/dart_api_dl.c
   )
 
@@ -189,6 +197,11 @@ if ($ENV{WEBF_JS_ENGINE} MATCHES "quickjs")
     third_party/quickjs/src/core/builtins/js-symbol.c
     third_party/quickjs/src/core/builtins/js-typed-array.c
   )
+
+  if (${CMAKE_BUILD_TYPE} MATCHES "Debug")
+    add_definitions(-DDDEBUG)
+  endif ()
+
   if(${STATIC_QUICKJS})
     add_library(quickjs STATIC ${QUICK_JS_SOURCE})
   else()
@@ -247,6 +260,8 @@ if ($ENV{WEBF_JS_ENGINE} MATCHES "quickjs")
     bindings/qjs/rejected_promises.cc
     bindings/qjs/union_base.cc
     # Core sources
+    webf_bridge.cc
+    core/api/api.cc
     core/executing_context.cc
     core/script_forbidden_scope.cc
     core/script_state.cc

bridge/bindings/qjs/script_wrappable.cc

@@ -30,6 +30,10 @@ ScriptValue ScriptWrappable::ToValue() {
   return ScriptValue(ctx_, jsObject_);
 }
 
+multi_threading::Dispatcher* ScriptWrappable::GetDispatcher() const {
+  return context_->dartIsolateContext()->dispatcher().get();
+}
+
 /// This callback will be called when QuickJS GC is running at marking stage.
 /// Users of this class should override `void TraceMember(JSRuntime* rt, JSValueConst val, JS_MarkFunc* mark_func)` to
 /// tell GC which member of their class should be collected by GC.
@@ -238,6 +242,8 @@ void ScriptWrappable::InitializeQuickJSObject() {
               desc->value = return_value;
               desc->getter = JS_NULL;
               desc->setter = JS_NULL;
+            } else {
+              JS_FreeValue(ctx, return_value);
             }
             return true;
           }
@@ -252,6 +258,8 @@ void ScriptWrappable::InitializeQuickJSObject() {
               desc->value = return_value;
               desc->getter = JS_NULL;
               desc->setter = JS_NULL;
+            } else {
+              JS_FreeValue(ctx, return_value);
             }
             return true;
           }

bridge/bindings/qjs/script_wrappable.h

@@ -9,6 +9,7 @@
 #include <quickjs/quickjs.h>
 #include "bindings/qjs/cppgc/garbage_collected.h"
 #include "foundation/macros.h"
+#include "multiple_threading/dispatcher.h"
 #include "wrapper_type_info.h"
 
 namespace webf {
@@ -52,6 +53,7 @@ class ScriptWrappable : public GarbageCollected<ScriptWrappable> {
 
   ScriptValue ToValue();
   FORCE_INLINE ExecutingContext* GetExecutingContext() const { return context_; };
+  multi_threading::Dispatcher* GetDispatcher() const;
   FORCE_INLINE JSContext* ctx() const { return ctx_; }
   FORCE_INLINE JSRuntime* runtime() const { return runtime_; }
   FORCE_INLINE int64_t contextId() const { return context_id_; }

bridge/core/api/api.cc

@@ -0,0 +1,88 @@
+/*
+ * Copyright (C) 2022-present The WebF authors. All rights reserved.
+ */
+
+#include "api.h"
+#include "core/dart_isolate_context.h"
+#include "core/html/parser/html_parser.h"
+#include "core/page.h"
+#include "multiple_threading/dispatcher.h"
+
+namespace webf {
+
+static void ReturnEvaluateScriptsInternal(Dart_PersistentHandle persistent_handle,
+                                          EvaluateQuickjsByteCodeCallback result_callback,
+                                          bool is_success) {
+  Dart_Handle handle = Dart_HandleFromPersistent_DL(persistent_handle);
+  result_callback(handle, is_success ? 1 : 0);
+  Dart_DeletePersistentHandle_DL(persistent_handle);
+}
+
+void evaluateScriptsInternal(void* page_,
+                             const char* code,
+                             uint64_t code_len,
+                             uint8_t** parsed_bytecodes,
+                             uint64_t* bytecode_len,
+                             const char* bundleFilename,
+                             int32_t startLine,
+                             Dart_Handle persistent_handle,
+                             EvaluateScriptsCallback result_callback) {
+  auto page = reinterpret_cast<webf::WebFPage*>(page_);
+  assert(std::this_thread::get_id() == page->currentThread());
+  bool is_success = page->evaluateScript(code, code_len, parsed_bytecodes, bytecode_len, bundleFilename, startLine);
+  page->dartIsolateContext()->dispatcher()->PostToDart(page->isDedicated(), ReturnEvaluateScriptsInternal,
+                                                       persistent_handle, result_callback, is_success);
+}
+
+static void ReturnEvaluateQuickjsByteCodeResultToDart(Dart_PersistentHandle persistent_handle,
+                                                      EvaluateQuickjsByteCodeCallback result_callback,
+                                                      bool is_success) {
+  Dart_Handle handle = Dart_HandleFromPersistent_DL(persistent_handle);
+  result_callback(handle, is_success ? 1 : 0);
+  Dart_DeletePersistentHandle_DL(persistent_handle);
+}
+
+void evaluateQuickjsByteCodeInternal(void* page_,
+                                     uint8_t* bytes,
+                                     int32_t byteLen,
+                                     Dart_PersistentHandle persistent_handle,
+                                     EvaluateQuickjsByteCodeCallback result_callback) {
+  auto page = reinterpret_cast<webf::WebFPage*>(page_);
+  assert(std::this_thread::get_id() == page->currentThread());
+  bool is_success = page->evaluateByteCode(bytes, byteLen);
+  page->dartIsolateContext()->dispatcher()->PostToDart(page->isDedicated(), ReturnEvaluateQuickjsByteCodeResultToDart,
+                                                       persistent_handle, result_callback, is_success);
+}
+
+void parseHTMLInternal(void* page_, const char* code, int32_t length) {
+  auto page = reinterpret_cast<webf::WebFPage*>(page_);
+  assert(std::this_thread::get_id() == page->currentThread());
+  page->parseHTML(code, length);
+  delete code;
+}
+
+static void ReturnInvokeEventResultToDart(Dart_Handle persistent_handle,
+                                          InvokeModuleEventCallback result_callback,
+                                          webf::NativeValue* result) {
+  Dart_Handle handle = Dart_HandleFromPersistent_DL(persistent_handle);
+  result_callback(handle, result);
+  Dart_DeletePersistentHandle_DL(persistent_handle);
+}
+
+void invokeModuleEventInternal(void* page_,
+                               void* module_name,
+                               const char* eventType,
+                               void* event,
+                               void* extra,
+                               Dart_Handle persistent_handle,
+                               InvokeModuleEventCallback result_callback) {
+  auto page = reinterpret_cast<webf::WebFPage*>(page_);
+  auto dart_isolate_context = page->executingContext()->dartIsolateContext();
+  assert(std::this_thread::get_id() == page->currentThread());
+  auto* result = page->invokeModuleEvent(reinterpret_cast<webf::SharedNativeString*>(module_name), eventType, event,
+                                         reinterpret_cast<webf::NativeValue*>(extra));
+  dart_isolate_context->dispatcher()->PostToDart(page->isDedicated(), ReturnInvokeEventResultToDart, persistent_handle,
+                                                 result_callback, result);
+}
+
+}  // namespace webf

bridge/core/api/api.h

@@ -0,0 +1,40 @@
+/*
+ * Copyright (C) 2022-present The WebF authors. All rights reserved.
+ */
+
+#ifndef WEBF_CORE_API_API_H_
+#define WEBF_CORE_API_API_H_
+
+#include <cassert>
+#include "include/webf_bridge.h"
+
+namespace webf {
+
+void evaluateScriptsInternal(void* page_,
+                             const char* code,
+                             uint64_t code_len,
+                             uint8_t** parsed_bytecodes,
+                             uint64_t* bytecode_len,
+                             const char* bundleFilename,
+                             int32_t startLine,
+                             Dart_Handle dart_handle,
+                             EvaluateScriptsCallback result_callback);
+
+void evaluateQuickjsByteCodeInternal(void* page_,
+                                     uint8_t* bytes,
+                                     int32_t byteLen,
+                                     Dart_PersistentHandle persistent_handle,
+                                     EvaluateQuickjsByteCodeCallback result_callback);
+void parseHTMLInternal(void* page_, const char* code, int32_t length);
+
+void invokeModuleEventInternal(void* page_,
+                               void* module_name,
+                               const char* eventType,
+                               void* event,
+                               void* extra,
+                               Dart_Handle dart_handle,
+                               InvokeModuleEventCallback result_callback);
+
+}  // namespace webf
+
+#endif  // WEBF_CORE_API_API_H_