diff --git a/React/CxxBridge/RCTCxxBridge.mm b/React/CxxBridge/RCTCxxBridge.mm
index 6f0aeed7c..cea1e0d84 100644
--- a/React/CxxBridge/RCTCxxBridge.mm
+++ b/React/CxxBridge/RCTCxxBridge.mm
@@ -210,6 +210,11 @@ struct RCTInstanceCallback : public InstanceCallback {
   return _jsMessageThread;
 }
 
+- (std::shared_ptr<Instance>)reactInstance
+{
+  return _reactInstance;
+}
+
 - (BOOL)isInspectable
 {
   return _reactInstance ? _reactInstance->isInspectable() : NO;
diff --git a/ReactCommon/cxxreact/Instance.cpp b/ReactCommon/cxxreact/Instance.cpp
index a9b6bd562..ad5069238 100644
--- a/ReactCommon/cxxreact/Instance.cpp
+++ b/ReactCommon/cxxreact/Instance.cpp
@@ -180,5 +180,12 @@ void Instance::handleMemoryPressure(int pressureLevel) {
   nativeToJsBridge_->handleMemoryPressure(pressureLevel);
 }
 
+void Instance::invokeAsync(std::function<void()>&& func) {
+  nativeToJsBridge_->runOnExecutorQueue([func=std::move(func)](JSExecutor *executor) {
+    func();
+    executor->flush();
+  });
+}
+
 } // namespace react
 } // namespace facebook
diff --git a/ReactCommon/cxxreact/Instance.h b/ReactCommon/cxxreact/Instance.h
index 72a5a7ee8..b72729660 100644
--- a/ReactCommon/cxxreact/Instance.h
+++ b/ReactCommon/cxxreact/Instance.h
@@ -71,6 +71,8 @@ public:
 
   void handleMemoryPressure(int pressureLevel);
 
+  void invokeAsync(std::function<void()>&& func);
+
 private:
   void callNativeModules(folly::dynamic &&calls, bool isEndOfBatch);
   void loadApplication(std::unique_ptr<RAMBundleRegistry> bundleRegistry,
diff --git a/ReactCommon/cxxreact/JSExecutor.h b/ReactCommon/cxxreact/JSExecutor.h
index f7cfd9752..bc2eb7d4e 100644
--- a/ReactCommon/cxxreact/JSExecutor.h
+++ b/ReactCommon/cxxreact/JSExecutor.h
@@ -108,6 +108,8 @@ public:
   virtual void destroy() {}
   virtual ~JSExecutor() {}
 
+  virtual void flush() {}
+
   static std::string getSyntheticBundlePath(
       uint32_t bundleId,
       const std::string& bundlePath);
diff --git a/ReactCommon/cxxreact/NativeToJsBridge.h b/ReactCommon/cxxreact/NativeToJsBridge.h
index cc30054ac..c80114230 100644
--- a/ReactCommon/cxxreact/NativeToJsBridge.h
+++ b/ReactCommon/cxxreact/NativeToJsBridge.h
@@ -83,9 +83,10 @@ public:
    * Synchronously tears down the bridge and the main executor.
    */
   void destroy();
-private:
+
   void runOnExecutorQueue(std::function<void(JSExecutor*)> task);
 
+private:
   // This is used to avoid a race condition where a proxyCallback gets queued
   // after ~NativeToJsBridge(), on the same thread. In that case, the callback
   // will try to run the task on m_callback which will have been destroyed
diff --git a/ReactCommon/jsiexecutor/jsireact/JSIExecutor.h b/ReactCommon/jsiexecutor/jsireact/JSIExecutor.h
index 1eea5d5bc..39c692f97 100644
--- a/ReactCommon/jsiexecutor/jsireact/JSIExecutor.h
+++ b/ReactCommon/jsiexecutor/jsireact/JSIExecutor.h
@@ -103,10 +103,11 @@ class JSIExecutor : public JSExecutor {
     invokee();
   }
 
+  void flush() override;
+
  private:
   class NativeModuleProxy;
 
-  void flush();
   void bindBridge();
   void callNativeModules(const jsi::Value &queue, bool isEndOfBatch);
   jsi::Value nativeCallSyncHook(const jsi::Value *args, size_t count);
diff --git a/ReactCommon/turbomodule/core/JSCallInvoker.cpp b/ReactCommon/turbomodule/core/JSCallInvoker.cpp
index ec28ce1c3..848e9de90 100644
--- a/ReactCommon/turbomodule/core/JSCallInvoker.cpp
+++ b/ReactCommon/turbomodule/core/JSCallInvoker.cpp
@@ -7,20 +7,19 @@
 
 #include "JSCallInvoker.h"
 
-#include <cxxreact/MessageQueueThread.h>
+#include <cxxreact/Instance.h>
 
 namespace facebook {
 namespace react {
 
-JSCallInvoker::JSCallInvoker(std::shared_ptr<MessageQueueThread> jsThread)
-  : jsThread_(jsThread) {}
+JSCallInvoker::JSCallInvoker(std::shared_ptr<Instance> reactInstance)
+  : reactInstance_(reactInstance) {}
 
 void JSCallInvoker::invokeAsync(std::function<void()>&& func) {
-  jsThread_->runOnQueue(std::move(func));
-}
-
-void JSCallInvoker::invokeSync(std::function<void()>&& func) {
-  jsThread_->runOnQueueSync(std::move(func));
+  if (reactInstance_ == nullptr) {
+    return;
+  }
+  reactInstance_->invokeAsync(std::move(func));
 }
 
 } // namespace react
diff --git a/ReactCommon/turbomodule/core/JSCallInvoker.h b/ReactCommon/turbomodule/core/JSCallInvoker.h
index 1f84bbc02..eff18fa87 100644
--- a/ReactCommon/turbomodule/core/JSCallInvoker.h
+++ b/ReactCommon/turbomodule/core/JSCallInvoker.h
@@ -13,25 +13,26 @@
 namespace facebook {
 namespace react {
 
-class MessageQueueThread;
+class Instance;
 
 /**
  * A generic native-to-JS call invoker. It guarantees that any calls from any
  * thread are queued on the right JS thread.
  *
- * For now, this is a thin-wrapper around existing MessageQueueThread. Eventually,
+ * For now, this is a thin-wrapper around existing bridge (`Instance`). Eventually,
  * it should be consolidated with Fabric implementation so there's only one
  * API to call JS from native, whether synchronously or asynchronously.
+ * Also, this class should not depend on `Instance` in the future.
  */
 class JSCallInvoker {
 public:
-  JSCallInvoker(std::shared_ptr<MessageQueueThread> jsThread);
+  JSCallInvoker(std::shared_ptr<Instance> reactInstance);
 
   void invokeAsync(std::function<void()>&& func);
-  void invokeSync(std::function<void()>&& func);
+  // TODO: add sync support
 
 private:
-  std::shared_ptr<MessageQueueThread> jsThread_;
+  std::shared_ptr<Instance> reactInstance_;
 };
 
 } // namespace react
diff --git a/ReactCommon/turbomodule/core/platform/ios/RCTTurboModule.h b/ReactCommon/turbomodule/core/platform/ios/RCTTurboModule.h
index da78e21e1..d63d69222 100644
--- a/ReactCommon/turbomodule/core/platform/ios/RCTTurboModule.h
+++ b/ReactCommon/turbomodule/core/platform/ios/RCTTurboModule.h
@@ -24,6 +24,8 @@
 namespace facebook {
 namespace react {
 
+class Instance;
+
 /**
  * ObjC++ specific TurboModule base class.
  */
@@ -89,5 +91,6 @@ private:
 @interface RCTBridge ()
 
 - (std::shared_ptr<facebook::react::MessageQueueThread>)jsMessageThread;
+- (std::shared_ptr<facebook::react::Instance>)reactInstance;
 
 @end
diff --git a/ReactCommon/turbomodule/core/platform/ios/RCTTurboModuleManager.mm b/ReactCommon/turbomodule/core/platform/ios/RCTTurboModuleManager.mm
index e6111517b..1a5e001ae 100644
--- a/ReactCommon/turbomodule/core/platform/ios/RCTTurboModuleManager.mm
+++ b/ReactCommon/turbomodule/core/platform/ios/RCTTurboModuleManager.mm
@@ -51,7 +51,7 @@ static Class getFallbackClassFromName(const char *name) {
 {
   if (self = [super init]) {
     _runtime = runtime;
-    _jsInvoker = std::make_shared<react::JSCallInvoker>(bridge.jsMessageThread);
+    _jsInvoker = std::make_shared<react::JSCallInvoker>(bridge.reactInstance);
     _delegate = delegate;
     _bridge = bridge;