19 #ifndef GRPC_CORE_LIB_IOMGR_EXECUTOR_H 20 #define GRPC_CORE_LIB_IOMGR_EXECUTOR_H 108 static void ThreadMain(
void* arg);
size_t depth
Definition: executor.h:36
grpc_core::Thread thd
Definition: executor.h:39
gpr_cv cv
Definition: executor.h:34
Executor(const char *executor_name)
Definition: executor.cc:92
ExecutorJobType
Definition: executor.h:49
Definition: executor.h:55
void grpc_executor_global_init()
Definition: executor.cc:467
static bool IsThreadedDefault()
Definition: executor.cc:450
static void InitAll()
Definition: executor.cc:385
Definition: executor.h:30
bool queued_long_job
Definition: executor.h:38
Definition: error_internal.h:39
Definition: spinlock.h:28
const char * name
Definition: executor.h:33
static void SetThreadingDefault(bool enable)
Definition: executor.cc:462
grpc_closure_list elems
Definition: executor.h:35
Round Robin Policy.
Definition: backend_metric.cc:24
bool shutdown
Definition: executor.h:37
ExecutorType
Definition: executor.h:42
pthread_cond_t gpr_cv
Definition: sync_posix.h:46
void Enqueue(grpc_closure *closure, grpc_error *error, bool is_short)
Enqueue the closure onto the executor.
Definition: executor.cc:254
static void ShutdownAll()
Definition: executor.cc:412
static void SetThreadingAll(bool enable)
Definition: executor.cc:454
void SetThreading(bool threading)
Definition: executor.cc:140
gpr_mu mu
Definition: executor.h:31
Definition: sync_windows.h:26
intptr_t gpr_atm
Definition: atm_gcc_atomic.h:30
void Init()
Definition: executor.cc:98
static void Run(grpc_closure *closure, grpc_error *error, ExecutorType executor_type=ExecutorType::DEFAULT, ExecutorJobType job_type=ExecutorJobType::SHORT)
Definition: executor.cc:406
A closure over a grpc_iomgr_cb_func.
Definition: closure.h:56
bool IsThreaded() const
Is the executor multi-threaded?
Definition: executor.cc:136
void Shutdown()
Shutdown the executor, running all pending work as part of the call.
Definition: executor.cc:213
size_t id
Definition: executor.h:32