From e19a1af6943126a73a5a13e1b9af63ce175d602c Mon Sep 17 00:00:00 2001
From: Craig Tiller <ctiller@google.com>
Date: Fri, 15 Nov 2024 09:01:59 -0800
Subject: [PATCH] use ee for max threadyness

---
 src/core/lib/promise/party.cc | 16 ++++------------
 1 file changed, 4 insertions(+), 12 deletions(-)

diff --git a/src/core/lib/promise/party.cc b/src/core/lib/promise/party.cc
index ed0e3af639b..4df20caa5a2 100644
--- a/src/core/lib/promise/party.cc
+++ b/src/core/lib/promise/party.cc
@@ -29,11 +29,6 @@
 #include "src/core/util/latent_see.h"
 #include "src/core/util/sync.h"
 
-#ifdef GRPC_MAXIMIZE_THREADYNESS
-#include "src/core/lib/iomgr/exec_ctx.h"  // IWYU pragma: keep
-#include "src/core/util/thd.h"            // IWYU pragma: keep
-#endif
-
 namespace grpc_core {
 
 ///////////////////////////////////////////////////////////////////////////////
@@ -193,16 +188,13 @@ void Party::ForceImmediateRepoll(WakeupMask mask) {
 
 void Party::RunLockedAndUnref(Party* party, uint64_t prev_state) {
   GRPC_LATENT_SEE_PARENT_SCOPE("Party::RunLocked");
-#ifdef GRPC_MAXIMIZE_THREADYNESS
-  Thread thd(
-      "RunParty",
-      [party, prev_state]() {
+#if defined(GRPC_MAXIMIZE_THREADYNESS)
+  party->arena_->GetContext<grpc_event_engine::experimental::EventEngine>()
+      ->Run([party, prev_state]() {
         ApplicationCallbackExecCtx app_exec_ctx;
         ExecCtx exec_ctx;
         party->RunPartyAndUnref(prev_state);
-      },
-      nullptr, Thread::Options().set_joinable(false));
-  thd.Start();
+      });
 #else
   struct RunState;
   static thread_local RunState* g_run_state = nullptr;