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