Revert "[party] use ee for max threadyness (#38139)" (#38153)

This reverts commit 3cc611c7df.

Closes #38153

COPYBARA_INTEGRATE_REVIEW=https://github.com/grpc/grpc/pull/38153 from ctiller:rb123 2fcbb7e4a0
PiperOrigin-RevId: 698097295
pull/38072/merge
Craig Tiller 6 days ago committed by Copybara-Service
parent 14e077f9bd
commit d61d88d130
  1. 16
      src/core/lib/promise/party.cc

@ -29,6 +29,11 @@
#include "src/core/util/latent_see.h" #include "src/core/util/latent_see.h"
#include "src/core/util/sync.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 { namespace grpc_core {
/////////////////////////////////////////////////////////////////////////////// ///////////////////////////////////////////////////////////////////////////////
@ -188,13 +193,16 @@ void Party::ForceImmediateRepoll(WakeupMask mask) {
void Party::RunLockedAndUnref(Party* party, uint64_t prev_state) { void Party::RunLockedAndUnref(Party* party, uint64_t prev_state) {
GRPC_LATENT_SEE_PARENT_SCOPE("Party::RunLocked"); GRPC_LATENT_SEE_PARENT_SCOPE("Party::RunLocked");
#if defined(GRPC_MAXIMIZE_THREADYNESS) #ifdef GRPC_MAXIMIZE_THREADYNESS
party->arena_->GetContext<grpc_event_engine::experimental::EventEngine>() Thread thd(
->Run([party, prev_state]() { "RunParty",
[party, prev_state]() {
ApplicationCallbackExecCtx app_exec_ctx; ApplicationCallbackExecCtx app_exec_ctx;
ExecCtx exec_ctx; ExecCtx exec_ctx;
party->RunPartyAndUnref(prev_state); party->RunPartyAndUnref(prev_state);
}); },
nullptr, Thread::Options().set_joinable(false));
thd.Start();
#else #else
struct RunState; struct RunState;
static thread_local RunState* g_run_state = nullptr; static thread_local RunState* g_run_state = nullptr;

Loading…
Cancel
Save