diff --git a/ci/licenses_golden/licenses_flutter b/ci/licenses_golden/licenses_flutter
index b8930211ebfab..b6d7374267808 100644
--- a/ci/licenses_golden/licenses_flutter
+++ b/ci/licenses_golden/licenses_flutter
@@ -1020,8 +1020,6 @@ FILE: ../../../flutter/shell/platform/fuchsia/flutter/kernel/extract_far.dart
 FILE: ../../../flutter/shell/platform/fuchsia/flutter/kernel/framework_shim.dart
 FILE: ../../../flutter/shell/platform/fuchsia/flutter/kernel/libraries.json
 FILE: ../../../flutter/shell/platform/fuchsia/flutter/logging.h
-FILE: ../../../flutter/shell/platform/fuchsia/flutter/loop.cc
-FILE: ../../../flutter/shell/platform/fuchsia/flutter/loop.h
 FILE: ../../../flutter/shell/platform/fuchsia/flutter/main.cc
 FILE: ../../../flutter/shell/platform/fuchsia/flutter/meta/aot_product_runtime
 FILE: ../../../flutter/shell/platform/fuchsia/flutter/meta/aot_runtime
@@ -1044,12 +1042,6 @@ FILE: ../../../flutter/shell/platform/fuchsia/flutter/session_connection.cc
 FILE: ../../../flutter/shell/platform/fuchsia/flutter/session_connection.h
 FILE: ../../../flutter/shell/platform/fuchsia/flutter/surface.cc
 FILE: ../../../flutter/shell/platform/fuchsia/flutter/surface.h
-FILE: ../../../flutter/shell/platform/fuchsia/flutter/task_observers.cc
-FILE: ../../../flutter/shell/platform/fuchsia/flutter/task_observers.h
-FILE: ../../../flutter/shell/platform/fuchsia/flutter/task_runner_adapter.cc
-FILE: ../../../flutter/shell/platform/fuchsia/flutter/task_runner_adapter.h
-FILE: ../../../flutter/shell/platform/fuchsia/flutter/thread.cc
-FILE: ../../../flutter/shell/platform/fuchsia/flutter/thread.h
 FILE: ../../../flutter/shell/platform/fuchsia/flutter/unique_fdio_ns.h
 FILE: ../../../flutter/shell/platform/fuchsia/flutter/vsync_recorder.cc
 FILE: ../../../flutter/shell/platform/fuchsia/flutter/vsync_recorder.h
diff --git a/fml/thread.cc b/fml/thread.cc
index b6a4802b48728..4f96fd7e08e9d 100644
--- a/fml/thread.cc
+++ b/fml/thread.cc
@@ -10,6 +10,8 @@
 
 #if defined(OS_WIN)
 #include <windows.h>
+#elif defined(OS_FUCHSIA)
+#include <lib/zx/thread.h>
 #else
 #include <pthread.h>
 #endif
@@ -85,6 +87,8 @@ void Thread::SetCurrentThreadName(const std::string& name) {
                    reinterpret_cast<DWORD_PTR*>(&info));
   } __except (EXCEPTION_CONTINUE_EXECUTION) {
   }
+#elif OS_FUCHSIA
+  zx::thread::self()->set_property(ZX_PROP_NAME, name.c_str(), name.size());
 #else
   FML_DLOG(INFO) << "Could not set the thread name to '" << name
                  << "' on this platform.";
diff --git a/shell/platform/fuchsia/flutter/BUILD.gn b/shell/platform/fuchsia/flutter/BUILD.gn
index 956ccc8a953f7..6e0b391d3815e 100644
--- a/shell/platform/fuchsia/flutter/BUILD.gn
+++ b/shell/platform/fuchsia/flutter/BUILD.gn
@@ -303,8 +303,6 @@ executable("flutter_runner_unittests") {
     "fuchsia_intl.h",
     "fuchsia_intl_unittest.cc",
     "logging.h",
-    "loop.cc",
-    "loop.h",
     "platform_view.cc",
     "platform_view.h",
     "platform_view_unittest.cc",
@@ -313,12 +311,6 @@ executable("flutter_runner_unittests") {
     "runner_unittest.cc",
     "surface.cc",
     "surface.h",
-    "task_observers.cc",
-    "task_observers.h",
-    "task_runner_adapter.cc",
-    "task_runner_adapter.h",
-    "thread.cc",
-    "thread.h",
     "vsync_recorder.cc",
     "vsync_recorder.h",
     "vsync_waiter.cc",
diff --git a/shell/platform/fuchsia/flutter/component.cc b/shell/platform/fuchsia/flutter/component.cc
index 9185914e531e6..dee414d344538 100644
--- a/shell/platform/fuchsia/flutter/component.cc
+++ b/shell/platform/fuchsia/flutter/component.cc
@@ -2,6 +2,8 @@
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
+#define FML_USED_ON_EMBEDDER
+
 #include "component.h"
 
 #include <dlfcn.h>
@@ -36,10 +38,6 @@
 #include "runtime/dart/utils/tempfs.h"
 #include "runtime/dart/utils/vmo.h"
 
-#include "task_observers.h"
-#include "task_runner_adapter.h"
-#include "thread.h"
-
 // TODO(kaushikiska): Use these constants from ::llcpp::fuchsia::io
 // Can read from target object.
 constexpr uint32_t OPEN_RIGHT_READABLE = 1u;
@@ -59,11 +57,11 @@ ActiveApplication Application::Create(
     fuchsia::sys::StartupInfo startup_info,
     std::shared_ptr<sys::ServiceDirectory> runner_incoming_services,
     fidl::InterfaceRequest<fuchsia::sys::ComponentController> controller) {
-  std::unique_ptr<Thread> thread = std::make_unique<Thread>();
+  std::unique_ptr<fml::Thread> thread = std::make_unique<fml::Thread>();
   std::unique_ptr<Application> application;
 
   fml::AutoResetWaitableEvent latch;
-  async::PostTask(thread->dispatcher(), [&]() mutable {
+  fml::TaskRunner::RunNowOrPostTask(thread->GetTaskRunner(), [&]() mutable {
     application.reset(
         new Application(std::move(termination_callback), std::move(package),
                         std::move(startup_info), runner_incoming_services,
@@ -347,12 +345,12 @@ Application::Application(
   settings_.disable_dart_asserts = true;
 #endif
 
-  settings_.task_observer_add =
-      std::bind(&CurrentMessageLoopAddAfterTaskObserver, std::placeholders::_1,
-                std::placeholders::_2);
-
-  settings_.task_observer_remove = std::bind(
-      &CurrentMessageLoopRemoveAfterTaskObserver, std::placeholders::_1);
+  settings_.task_observer_add = [](intptr_t key, fml::closure callback) {
+    fml::MessageLoop::GetCurrent().AddTaskObserver(key, std::move(callback));
+  };
+  settings_.task_observer_remove = [](intptr_t key) {
+    fml::MessageLoop::GetCurrent().RemoveTaskObserver(key);
+  };
 
   // TODO(FL-117): Re-enable causal async stack traces when this issue is
   // addressed.
@@ -379,8 +377,7 @@ Application::Application(
 #endif  // defined(__aarch64__)
 
   auto weak_application = weak_factory_.GetWeakPtr();
-  auto platform_task_runner =
-      CreateFMLTaskRunner(async_get_default_dispatcher());
+  auto platform_task_runner = fml::MessageLoop::GetCurrent().GetTaskRunner();
   const std::string component_url = package.resolved_url;
   settings_.unhandled_exception_callback = [weak_application,
                                             platform_task_runner,
diff --git a/shell/platform/fuchsia/flutter/component.h b/shell/platform/fuchsia/flutter/component.h
index b852d3dd6bcd2..4843463496127 100644
--- a/shell/platform/fuchsia/flutter/component.h
+++ b/shell/platform/fuchsia/flutter/component.h
@@ -24,8 +24,8 @@
 #include "engine.h"
 #include "flutter/common/settings.h"
 #include "flutter/fml/macros.h"
+#include "flutter/fml/thread.h"
 
-#include "thread.h"
 #include "unique_fdio_ns.h"
 
 namespace flutter_runner {
@@ -33,7 +33,7 @@ namespace flutter_runner {
 class Application;
 
 struct ActiveApplication {
-  std::unique_ptr<Thread> thread;
+  std::unique_ptr<fml::Thread> thread;
   std::unique_ptr<Application> application;
 
   ActiveApplication& operator=(ActiveApplication&& other) noexcept {
diff --git a/shell/platform/fuchsia/flutter/engine.cc b/shell/platform/fuchsia/flutter/engine.cc
index 4d8277ba5d27e..484d5b8145cd3 100644
--- a/shell/platform/fuchsia/flutter/engine.cc
+++ b/shell/platform/fuchsia/flutter/engine.cc
@@ -2,6 +2,8 @@
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
+#define FML_USED_ON_EMBEDDER
+
 #include "engine.h"
 
 #include <lib/async/cpp/task.h>
@@ -18,9 +20,7 @@
 #include "fuchsia_intl.h"
 #include "platform_view.h"
 #include "runtime/dart/utils/files.h"
-#include "task_runner_adapter.h"
 #include "third_party/skia/include/ports/SkFontMgr_fuchsia.h"
-#include "thread.h"
 
 namespace flutter_runner {
 
@@ -60,6 +60,10 @@ Engine::Engine(Delegate& delegate,
                fidl::InterfaceRequest<fuchsia::io::Directory> directory_request)
     : delegate_(delegate),
       thread_label_(std::move(thread_label)),
+      thread_host_(thread_label_ + ".",
+                   flutter::ThreadHost::Type::IO |
+                       flutter::ThreadHost::Type::UI |
+                       flutter::ThreadHost::Type::GPU),
       settings_(std::move(settings)),
       weak_factory_(this) {
   if (zx::event::create(0, &vsync_event_) != ZX_OK) {
@@ -67,12 +71,6 @@ Engine::Engine(Delegate& delegate,
     return;
   }
 
-  // Launch the threads that will be used to run the shell. These threads will
-  // be joined in the destructor.
-  for (auto& thread : threads_) {
-    thread.reset(new Thread());
-  }
-
   // Set up the session connection.
   auto scenic = svc->Connect<fuchsia::ui::scenic::Scenic>();
   fidl::InterfaceHandle<fuchsia::ui::scenic::Session> session;
@@ -167,12 +165,14 @@ Engine::Engine(Delegate& delegate,
 
   // Get the task runners from the managed threads. The current thread will be
   // used as the "platform" thread.
+  fml::MessageLoop::EnsureInitializedForCurrentThread();
+
   const flutter::TaskRunners task_runners(
-      thread_label_,  // Dart thread labels
-      CreateFMLTaskRunner(async_get_default_dispatcher()),  // platform
-      CreateFMLTaskRunner(threads_[0]->dispatcher()),       // gpu
-      CreateFMLTaskRunner(threads_[1]->dispatcher()),       // ui
-      CreateFMLTaskRunner(threads_[2]->dispatcher())        // io
+      thread_label_,                                   // Dart thread labels
+      fml::MessageLoop::GetCurrent().GetTaskRunner(),  // platform
+      thread_host_.gpu_thread->GetTaskRunner(),        // gpu
+      thread_host_.ui_thread->GetTaskRunner(),         // ui
+      thread_host_.io_thread->GetTaskRunner()          // io
   );
 
   // Setup the callback that will instantiate the rasterizer.
@@ -353,12 +353,6 @@ Engine::Engine(Delegate& delegate,
 
 Engine::~Engine() {
   shell_.reset();
-  for (const auto& thread : threads_) {
-    thread->Quit();
-  }
-  for (const auto& thread : threads_) {
-    thread->Join();
-  }
 }
 
 std::pair<bool, uint32_t> Engine::GetEngineReturnCode() const {
diff --git a/shell/platform/fuchsia/flutter/engine.h b/shell/platform/fuchsia/flutter/engine.h
index 6f045e330aa03..f1171b5ad3487 100644
--- a/shell/platform/fuchsia/flutter/engine.h
+++ b/shell/platform/fuchsia/flutter/engine.h
@@ -16,8 +16,8 @@
 
 #include "flutter/fml/macros.h"
 #include "flutter/shell/common/shell.h"
+#include "flutter/shell/common/thread_host.h"
 #include "isolate_configurator.h"
-#include "thread.h"
 
 namespace flutter_runner {
 
@@ -53,8 +53,8 @@ class Engine final {
  private:
   Delegate& delegate_;
   const std::string thread_label_;
+  flutter::ThreadHost thread_host_;
   flutter::Settings settings_;
-  std::array<std::unique_ptr<Thread>, 3> threads_;
   std::unique_ptr<IsolateConfigurator> isolate_configurator_;
   std::unique_ptr<flutter::Shell> shell_;
   zx::event vsync_event_;
diff --git a/shell/platform/fuchsia/flutter/engine_flutter_runner.gni b/shell/platform/fuchsia/flutter/engine_flutter_runner.gni
index 59ec0366d6786..3105bded8b50d 100644
--- a/shell/platform/fuchsia/flutter/engine_flutter_runner.gni
+++ b/shell/platform/fuchsia/flutter/engine_flutter_runner.gni
@@ -55,8 +55,6 @@ template("flutter_runner") {
       "isolate_configurator.cc",
       "isolate_configurator.h",
       "logging.h",
-      "loop.cc",
-      "loop.h",
       "main.cc",
       "platform_view.cc",
       "platform_view.h",
@@ -66,12 +64,6 @@ template("flutter_runner") {
       "session_connection.h",
       "surface.cc",
       "surface.h",
-      "task_observers.cc",
-      "task_observers.h",
-      "task_runner_adapter.cc",
-      "task_runner_adapter.h",
-      "thread.cc",
-      "thread.h",
       "unique_fdio_ns.h",
       "vsync_recorder.cc",
       "vsync_recorder.h",
diff --git a/shell/platform/fuchsia/flutter/fuchsia_intl.cc b/shell/platform/fuchsia/flutter/fuchsia_intl.cc
index e1f4fa6238ce0..f6b322befb945 100644
--- a/shell/platform/fuchsia/flutter/fuchsia_intl.cc
+++ b/shell/platform/fuchsia/flutter/fuchsia_intl.cc
@@ -8,7 +8,6 @@
 #include <string>
 #include <vector>
 
-#include "loop.h"
 #include "rapidjson/document.h"
 #include "rapidjson/stringbuffer.h"
 #include "rapidjson/writer.h"
diff --git a/shell/platform/fuchsia/flutter/loop.cc b/shell/platform/fuchsia/flutter/loop.cc
deleted file mode 100644
index 6518828c7a96e..0000000000000
--- a/shell/platform/fuchsia/flutter/loop.cc
+++ /dev/null
@@ -1,47 +0,0 @@
-// Copyright 2013 The Flutter Authors. All rights reserved.
-// Use of this source code is governed by a BSD-style license that can be
-// found in the LICENSE file.
-
-#include "loop.h"
-
-#include <lib/async-loop/loop.h>
-#include <lib/async/default.h>
-
-#include "task_observers.h"
-
-namespace flutter_runner {
-
-namespace {
-
-static void LoopEpilogue(async_loop_t*, void*) {
-  ExecuteAfterTaskObservers();
-}
-
-constexpr async_loop_config_t kAttachedLoopConfig = {
-    .default_accessors =
-        {
-            .getter = async_get_default_dispatcher,
-            .setter = async_set_default_dispatcher,
-        },
-    .make_default_for_current_thread = true,
-    .epilogue = &LoopEpilogue,
-};
-
-constexpr async_loop_config_t kDetachedLoopConfig = {
-    .default_accessors =
-        {
-            .getter = async_get_default_dispatcher,
-            .setter = async_set_default_dispatcher,
-        },
-    .make_default_for_current_thread = false,
-    .epilogue = &LoopEpilogue,
-};
-
-}  // namespace
-
-async::Loop* MakeObservableLoop(bool attachToThread) {
-  return new async::Loop(
-      &(attachToThread ? kAttachedLoopConfig : kDetachedLoopConfig));
-}
-
-}  // namespace flutter_runner
diff --git a/shell/platform/fuchsia/flutter/loop.h b/shell/platform/fuchsia/flutter/loop.h
deleted file mode 100644
index 02339febadf4c..0000000000000
--- a/shell/platform/fuchsia/flutter/loop.h
+++ /dev/null
@@ -1,17 +0,0 @@
-// Copyright 2013 The Flutter Authors. All rights reserved.
-// Use of this source code is governed by a BSD-style license that can be
-// found in the LICENSE file.
-
-#ifndef FLUTTER_SHELL_PLATFORM_FUCHSIA_LOOP_H_
-#define FLUTTER_SHELL_PLATFORM_FUCHSIA_LOOP_H_
-
-#include <lib/async-loop/cpp/loop.h>
-
-namespace flutter_runner {
-
-// Creates a loop which allows task observers to be attached to it.
-async::Loop* MakeObservableLoop(bool attachToThread);
-
-}  // namespace flutter_runner
-
-#endif  // FLUTTER_SHELL_PLATFORM_FUCHSIA_LOOP_H_
diff --git a/shell/platform/fuchsia/flutter/main.cc b/shell/platform/fuchsia/flutter/main.cc
index e37a12d275634..e8d2b21c8d749 100644
--- a/shell/platform/fuchsia/flutter/main.cc
+++ b/shell/platform/fuchsia/flutter/main.cc
@@ -2,18 +2,21 @@
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
+#define FML_USED_ON_EMBEDDER
+
 #include <lib/async-loop/cpp/loop.h>
+#include <lib/async-loop/default.h>
 #include <lib/trace-provider/provider.h>
 #include <lib/trace/event.h>
 
 #include <cstdlib>
 
-#include "loop.h"
 #include "runner.h"
 #include "runtime/dart/utils/tempfs.h"
 
 int main(int argc, char const* argv[]) {
-  std::unique_ptr<async::Loop> loop(flutter_runner::MakeObservableLoop(true));
+  fml::MessageLoop::EnsureInitializedForCurrentThread();
+  auto& message_loop = fml::MessageLoop::GetCurrent();
 
   std::unique_ptr<trace::TraceProviderWithFdio> provider;
   {
@@ -21,7 +24,8 @@ int main(int argc, char const* argv[]) {
     bool already_started;
     // Use CreateSynchronously to prevent loss of early events.
     trace::TraceProviderWithFdio::CreateSynchronously(
-        loop->dispatcher(), "flutter_runner", &provider, &already_started);
+        async_get_default_dispatcher(), "flutter_runner", &provider,
+        &already_started);
   }
 
   // Set up the process-wide /tmp memfs.
@@ -29,9 +33,9 @@ int main(int argc, char const* argv[]) {
 
   FML_DLOG(INFO) << "Flutter application services initialized.";
 
-  flutter_runner::Runner runner(loop.get());
+  flutter_runner::Runner runner(message_loop);
 
-  loop->Run();
+  message_loop.Run();
 
   FML_DLOG(INFO) << "Flutter application services terminated.";
 
diff --git a/shell/platform/fuchsia/flutter/runner.cc b/shell/platform/fuchsia/flutter/runner.cc
index 2fe0b5626ada6..3b4b1b13734c3 100644
--- a/shell/platform/fuchsia/flutter/runner.cc
+++ b/shell/platform/fuchsia/flutter/runner.cc
@@ -2,6 +2,8 @@
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
+#define FML_USED_ON_EMBEDDER
+
 #include "runner.h"
 
 #include <fuchsia/mem/cpp/fidl.h>
@@ -128,11 +130,6 @@ static void SetProcessName() {
   zx::process::self()->set_property(ZX_PROP_NAME, name.c_str(), name.size());
 }
 
-static void SetThreadName(const std::string& thread_name) {
-  zx::thread::self()->set_property(ZX_PROP_NAME, thread_name.c_str(),
-                                   thread_name.size());
-}
-
 #if !defined(DART_PRODUCT)
 // Register native symbol information for the Dart VM's profiler.
 static void RegisterProfilerSymbols(const char* symbols_path,
@@ -146,8 +143,8 @@ static void RegisterProfilerSymbols(const char* symbols_path,
 }
 #endif  // !defined(DART_PRODUCT)
 
-Runner::Runner(async::Loop* loop)
-    : loop_(loop), context_(sys::ComponentContext::Create()) {
+Runner::Runner(fml::MessageLoop& message_loop)
+    : message_loop_(message_loop), context_(sys::ComponentContext::Create()) {
 #if !defined(DART_PRODUCT)
   // The VM service isolate uses the process-wide namespace. It writes the
   // vm service protocol port under /tmp. The VMServiceObject exposes that
@@ -165,7 +162,7 @@ Runner::Runner(async::Loop* loop)
 
   SetProcessName();
 
-  SetThreadName("io.flutter.runner.main");
+  fml::Thread::SetCurrentThreadName("io.flutter.runner.main");
 
   context_->outgoing()->AddPublicService<fuchsia::sys::Runner>(
       std::bind(&Runner::RegisterApplication, this, std::placeholders::_1));
@@ -214,12 +211,13 @@ void Runner::StartComponent(
   // there being multiple application runner instance in the process at the same
   // time. So it is safe to use the raw pointer.
   Application::TerminationCallback termination_callback =
-      [task_runner = loop_->dispatcher(),  //
-       application_runner = this           //
+      [task_runner = message_loop_.GetTaskRunner(),  //
+       application_runner = this                     //
   ](const Application* application) {
-        async::PostTask(task_runner, [application_runner, application]() {
-          application_runner->OnApplicationTerminate(application);
-        });
+        fml::TaskRunner::RunNowOrPostTask(
+            task_runner, [application_runner, application]() {
+              application_runner->OnApplicationTerminate(application);
+            });
       };
 
   auto active_application = Application::Create(
@@ -254,13 +252,11 @@ void Runner::OnApplicationTerminate(const Application* application) {
   active_applications_.erase(application);
 
   // Post the task to destroy the application and quit its message loop.
-  async::PostTask(
-      application_thread->dispatcher(),
-      fml::MakeCopyable([instance = std::move(application_to_destroy),
-                         thread = application_thread.get()]() mutable {
-        instance.reset();
-        thread->Quit();
-      }));
+  fml::TaskRunner::RunNowOrPostTask(
+      application_thread->GetTaskRunner(),
+      fml::MakeCopyable(
+          [instance = std::move(application_to_destroy),
+           thread = application_thread.get()]() mutable { instance.reset(); }));
 
   // This works because just posted the quit task on the hosted thread.
   application_thread->Join();
@@ -287,7 +283,8 @@ bool Runner::SetupTZDataInternal() {
 #if !defined(DART_PRODUCT)
 void Runner::SetupTraceObserver() {
   trace_observer_ = std::make_unique<trace::TraceObserver>();
-  trace_observer_->Start(loop_->dispatcher(), [runner = this]() {
+  FML_DCHECK(message_loop_.GetTaskRunner()->RunsTasksOnCurrentThread());
+  trace_observer_->Start(async_get_default_dispatcher(), [runner = this]() {
     if (!trace_is_category_enabled("dart:profiler")) {
       return;
     }
@@ -297,10 +294,11 @@ void Runner::SetupTraceObserver() {
     } else if (trace_state() == TRACE_STOPPING) {
       for (auto& it : runner->active_applications_) {
         fml::AutoResetWaitableEvent latch;
-        async::PostTask(it.second.thread->dispatcher(), [&]() {
-          it.second.application->WriteProfileToTrace();
-          latch.Signal();
-        });
+        fml::TaskRunner::RunNowOrPostTask(
+            it.second.thread->GetTaskRunner(), [&]() {
+              it.second.application->WriteProfileToTrace();
+              latch.Signal();
+            });
         latch.Wait();
       }
       Dart_StopProfiling();
diff --git a/shell/platform/fuchsia/flutter/runner.h b/shell/platform/fuchsia/flutter/runner.h
index 4abba33a6060f..fd3f0785da2fa 100644
--- a/shell/platform/fuchsia/flutter/runner.h
+++ b/shell/platform/fuchsia/flutter/runner.h
@@ -25,13 +25,12 @@ namespace flutter_runner {
 // their own threads.
 class Runner final : public fuchsia::sys::Runner {
  public:
-  explicit Runner(async::Loop* loop);
+  explicit Runner(fml::MessageLoop& message_loop);
 
   ~Runner();
 
  private:
-  async::Loop* loop_;
-
+  fml::MessageLoop& message_loop_;
   std::unique_ptr<sys::ComponentContext> context_;
   fidl::BindingSet<fuchsia::sys::Runner> active_applications_bindings_;
   std::unordered_map<const Application*, ActiveApplication>
diff --git a/shell/platform/fuchsia/flutter/task_observers.cc b/shell/platform/fuchsia/flutter/task_observers.cc
deleted file mode 100644
index 7a623684ff66e..0000000000000
--- a/shell/platform/fuchsia/flutter/task_observers.cc
+++ /dev/null
@@ -1,30 +0,0 @@
-// Copyright 2013 The Flutter Authors. All rights reserved.
-// Use of this source code is governed by a BSD-style license that can be
-// found in the LICENSE file.
-
-#include "task_observers.h"
-
-#include <map>
-
-namespace flutter_runner {
-
-thread_local std::map<intptr_t, fit::closure> tTaskObservers;
-
-void ExecuteAfterTaskObservers() {
-  for (const auto& callback : tTaskObservers) {
-    callback.second();
-  }
-}
-
-void CurrentMessageLoopAddAfterTaskObserver(intptr_t key,
-                                            fit::closure observer) {
-  if (observer) {
-    tTaskObservers[key] = std::move(observer);
-  }
-}
-
-void CurrentMessageLoopRemoveAfterTaskObserver(intptr_t key) {
-  tTaskObservers.erase(key);
-}
-
-}  // namespace flutter_runner
diff --git a/shell/platform/fuchsia/flutter/task_observers.h b/shell/platform/fuchsia/flutter/task_observers.h
deleted file mode 100644
index 5ee27d77e0c5c..0000000000000
--- a/shell/platform/fuchsia/flutter/task_observers.h
+++ /dev/null
@@ -1,21 +0,0 @@
-// Copyright 2013 The Flutter Authors. All rights reserved.
-// Use of this source code is governed by a BSD-style license that can be
-// found in the LICENSE file.
-
-#ifndef FLUTTER_SHELL_PLATFORM_FUCHSIA_TASK_OBSERVERS_H_
-#define FLUTTER_SHELL_PLATFORM_FUCHSIA_TASK_OBSERVERS_H_
-
-#include <lib/fit/function.h>
-
-namespace flutter_runner {
-
-void ExecuteAfterTaskObservers();
-
-void CurrentMessageLoopAddAfterTaskObserver(intptr_t key,
-                                            fit::closure observer);
-
-void CurrentMessageLoopRemoveAfterTaskObserver(intptr_t key);
-
-}  // namespace flutter_runner
-
-#endif  // FLUTTER_SHELL_PLATFORM_FUCHSIA_TASK_OBSERVERS_H_
diff --git a/shell/platform/fuchsia/flutter/task_runner_adapter.cc b/shell/platform/fuchsia/flutter/task_runner_adapter.cc
deleted file mode 100644
index e75cc16e3914e..0000000000000
--- a/shell/platform/fuchsia/flutter/task_runner_adapter.cc
+++ /dev/null
@@ -1,56 +0,0 @@
-// Copyright 2013 The Flutter Authors. All rights reserved.
-// Use of this source code is governed by a BSD-style license that can be
-// found in the LICENSE file.
-
-#include "task_runner_adapter.h"
-
-#include <lib/async/cpp/task.h>
-#include <lib/async/default.h>
-#include <lib/zx/time.h>
-
-#include "flutter/fml/message_loop_impl.h"
-
-namespace flutter_runner {
-
-class CompatTaskRunner : public fml::TaskRunner {
- public:
-  CompatTaskRunner(async_dispatcher_t* dispatcher)
-      : fml::TaskRunner(nullptr), forwarding_target_(dispatcher) {
-    FML_DCHECK(forwarding_target_);
-  }
-
-  void PostTask(const fml::closure& task) override {
-    async::PostTask(forwarding_target_, task);
-  }
-
-  void PostTaskForTime(const fml::closure& task,
-                       fml::TimePoint target_time) override {
-    async::PostTaskForTime(
-        forwarding_target_, task,
-        zx::time(target_time.ToEpochDelta().ToNanoseconds()));
-  }
-
-  void PostDelayedTask(const fml::closure& task,
-                       fml::TimeDelta delay) override {
-    async::PostDelayedTask(forwarding_target_, task,
-                           zx::duration(delay.ToNanoseconds()));
-  }
-
-  bool RunsTasksOnCurrentThread() override {
-    return forwarding_target_ == async_get_default_dispatcher();
-  }
-
- private:
-  async_dispatcher_t* forwarding_target_;
-
-  FML_DISALLOW_COPY_AND_ASSIGN(CompatTaskRunner);
-  FML_FRIEND_MAKE_REF_COUNTED(CompatTaskRunner);
-  FML_FRIEND_REF_COUNTED_THREAD_SAFE(CompatTaskRunner);
-};
-
-fml::RefPtr<fml::TaskRunner> CreateFMLTaskRunner(
-    async_dispatcher_t* dispatcher) {
-  return fml::MakeRefCounted<CompatTaskRunner>(dispatcher);
-}
-
-}  // namespace flutter_runner
diff --git a/shell/platform/fuchsia/flutter/task_runner_adapter.h b/shell/platform/fuchsia/flutter/task_runner_adapter.h
deleted file mode 100644
index 649b2a31e4d6c..0000000000000
--- a/shell/platform/fuchsia/flutter/task_runner_adapter.h
+++ /dev/null
@@ -1,16 +0,0 @@
-// Copyright 2013 The Flutter 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 <lib/async/dispatcher.h>
-
-#include "flutter/fml/task_runner.h"
-
-namespace flutter_runner {
-
-fml::RefPtr<fml::TaskRunner> CreateFMLTaskRunner(
-    async_dispatcher_t* dispatcher);
-
-}  // namespace flutter_runner
diff --git a/shell/platform/fuchsia/flutter/thread.cc b/shell/platform/fuchsia/flutter/thread.cc
deleted file mode 100644
index f15ea309a239d..0000000000000
--- a/shell/platform/fuchsia/flutter/thread.cc
+++ /dev/null
@@ -1,103 +0,0 @@
-// Copyright 2013 The Flutter Authors. All rights reserved.
-// Use of this source code is governed by a BSD-style license that can be
-// found in the LICENSE file.
-
-#include "thread.h"
-
-#include <limits.h>
-#include <unistd.h>
-
-#include <algorithm>
-
-#include <lib/async-loop/cpp/loop.h>
-
-#include "flutter/fml/logging.h"
-#include "loop.h"
-
-namespace flutter_runner {
-
-typedef void (*ThreadEntry)(Thread*);
-
-namespace {
-
-size_t NextPageSizeMultiple(size_t size) {
-  const size_t page_size = sysconf(_SC_PAGE_SIZE);
-  FML_CHECK(page_size != 0);
-
-  size = std::max<size_t>(size, page_size);
-
-  size_t rem = size % page_size;
-
-  if (rem == 0) {
-    return size;
-  }
-
-  return size + page_size - rem;
-}
-
-bool CreateThread(pthread_t* thread,
-                  ThreadEntry main,
-                  Thread* argument,
-                  size_t stack_size) {
-  pthread_attr_t thread_attributes;
-
-  if (pthread_attr_init(&thread_attributes) != 0) {
-    return false;
-  }
-
-  stack_size = std::max<size_t>(NextPageSizeMultiple(PTHREAD_STACK_MIN),
-                                NextPageSizeMultiple(stack_size));
-
-  if (pthread_attr_setstacksize(&thread_attributes, stack_size) != 0) {
-    return false;
-  }
-
-  auto result =
-      pthread_create(thread, &thread_attributes,
-                     reinterpret_cast<void* (*)(void*)>(main), argument);
-
-  pthread_attr_destroy(&thread_attributes);
-
-  return result == 0;
-}
-
-}  // anonymous namespace
-
-Thread::Thread() {
-  loop_.reset(MakeObservableLoop(false));
-  valid_ = CreateThread(
-      &thread_, [](Thread* thread) { thread->Main(); }, this, 1 << 20);
-}
-
-Thread::~Thread() {
-  Join();
-}
-
-bool Thread::IsValid() const {
-  return valid_;
-}
-
-async_dispatcher_t* Thread::dispatcher() const {
-  return loop_->dispatcher();
-}
-
-void Thread::Main() {
-  async_set_default_dispatcher(loop_->dispatcher());
-  loop_->Run();
-}
-
-void Thread::Quit() {
-  loop_->Quit();
-}
-
-bool Thread::Join() {
-  if (!valid_) {
-    return false;
-  }
-
-  bool result = pthread_join(thread_, nullptr) == 0;
-  valid_ = false;
-  return result;
-}
-
-}  // namespace flutter_runner
diff --git a/shell/platform/fuchsia/flutter/thread.h b/shell/platform/fuchsia/flutter/thread.h
deleted file mode 100644
index 00d1cef9492dd..0000000000000
--- a/shell/platform/fuchsia/flutter/thread.h
+++ /dev/null
@@ -1,45 +0,0 @@
-// Copyright 2013 The Flutter Authors. All rights reserved.
-// Use of this source code is governed by a BSD-style license that can be
-// found in the LICENSE file.
-
-#ifndef FLUTTER_SHELL_PLATFORM_FUCHSIA_THREAD_H_
-#define FLUTTER_SHELL_PLATFORM_FUCHSIA_THREAD_H_
-
-#include <pthread.h>
-
-#include <functional>
-
-#include <lib/async-loop/cpp/loop.h>
-#include <lib/async/default.h>
-
-#include "flutter/fml/macros.h"
-
-namespace flutter_runner {
-
-class Thread {
- public:
-  Thread();
-
-  ~Thread();
-
-  void Quit();
-
-  bool Join();
-
-  bool IsValid() const;
-
-  async_dispatcher_t* dispatcher() const;
-
- private:
-  bool valid_;
-  pthread_t thread_;
-  std::unique_ptr<async::Loop> loop_;
-
-  void Main();
-
-  FML_DISALLOW_COPY_AND_ASSIGN(Thread);
-};
-
-}  // namespace flutter_runner
-
-#endif  // FLUTTER_SHELL_PLATFORM_FUCHSIA_THREAD_H_
diff --git a/shell/platform/fuchsia/flutter/vsync_waiter_unittests.cc b/shell/platform/fuchsia/flutter/vsync_waiter_unittests.cc
index f1bcfc12ba350..67bdf3e03f9a7 100644
--- a/shell/platform/fuchsia/flutter/vsync_waiter_unittests.cc
+++ b/shell/platform/fuchsia/flutter/vsync_waiter_unittests.cc
@@ -14,8 +14,6 @@
 #include "flutter/fml/time/time_point.h"
 #include "flutter/shell/common/thread_host.h"
 #include "flutter/shell/common/vsync_waiter.h"
-#include "flutter/shell/platform/fuchsia/flutter/task_runner_adapter.h"
-#include "flutter/shell/platform/fuchsia/flutter/thread.h"
 #include "flutter/shell/platform/fuchsia/flutter/vsync_waiter.h"
 
 namespace flutter_runner_test {
@@ -50,21 +48,17 @@ class VsyncWaiterTest : public testing::Test {
 };
 
 TEST_F(VsyncWaiterTest, AwaitVsync) {
-  std::array<std::unique_ptr<flutter_runner::Thread>, 3> threads;
-
-  for (auto& thread : threads) {
-    thread.reset(new flutter_runner::Thread());
-  }
-
-  async::Loop loop(&kAsyncLoopConfigAttachToCurrentThread);
+  flutter::ThreadHost thread_host(
+      "VsyncWaiterTests.",
+      flutter::ThreadHost::Type::Platform | flutter::ThreadHost::Type::IO |
+          flutter::ThreadHost::Type::UI | flutter::ThreadHost::Type::GPU);
 
   const flutter::TaskRunners task_runners(
-      "VsyncWaiterTests",  // Dart thread labels
-      flutter_runner::CreateFMLTaskRunner(
-          async_get_default_dispatcher()),  // platform
-      flutter_runner::CreateFMLTaskRunner(threads[0]->dispatcher()),  // gpu
-      flutter_runner::CreateFMLTaskRunner(threads[1]->dispatcher()),  // ui
-      flutter_runner::CreateFMLTaskRunner(threads[2]->dispatcher())   // io
+      "VsyncWaiterTests",                            // Dart thread labels
+      thread_host.platform_thread->GetTaskRunner(),  // platform
+      thread_host.gpu_thread->GetTaskRunner(),       // gpu
+      thread_host.ui_thread->GetTaskRunner(),        // ui
+      thread_host.io_thread->GetTaskRunner()         // io
   );
 
   auto vsync_waiter = CreateVsyncWaiter(std::move(task_runners));
@@ -82,9 +76,6 @@ TEST_F(VsyncWaiterTest, AwaitVsync) {
   EXPECT_FALSE(did_timeout);
 
   vsync_waiter.reset();
-  for (const auto& thread : threads) {
-    thread->Quit();
-  }
 }
 
 TEST_F(VsyncWaiterTest, SnapToNextPhaseOverlapsWithNow) {