grpc_event_engine::iomgr_engine::ThreadPool Class Reference

#include <thread_pool.h>

Inheritance diagram for grpc_event_engine::iomgr_engine::ThreadPool:

Classes
class	Thread

Public Member Functions
void	Add (const std::function< void()> &callback)
void	PostforkChild () override
void	PostforkParent () override
void	PrepareFork () override
	ThreadPool (int reserve_threads)
	~ThreadPool () override
Public Member Functions inherited from grpc_event_engine::experimental::Forkable
	Forkable ()
virtual	~Forkable ()

Private Member Functions
void	StartNThreadsLocked (int n) ABSL_EXCLUSIVE_LOCKS_REQUIRED(&mu_)
void	ThreadFunc ()

Static Private Member Functions
static void	ReapThreads (std::vector< Thread * > *tlist)

Private Attributes
std::queue< std::function< void()> >	callbacks_
grpc_core::CondVar	cv_
std::vector< Thread * >	dead_threads_
grpc_core::CondVar	fork_cv_
bool	forking_
grpc_core::Mutex	mu_
int	nthreads_
int	reserve_threads_
bool	shutdown_
grpc_core::CondVar	shutdown_cv_
int	threads_waiting_

Detailed Description

Definition at line 37 of file src/core/lib/event_engine/iomgr_engine/thread_pool.h.

Constructor & Destructor Documentation

ThreadPool()

grpc_event_engine::iomgr_engine::ThreadPool::ThreadPool ( int  reserve_threads )

explicit

Definition at line 80 of file thread_pool.cc.

~ThreadPool()

grpc_event_engine::iomgr_engine::ThreadPool::~ThreadPool ( )

override

Definition at line 102 of file thread_pool.cc.

Member Function Documentation

Add()

void grpc_event_engine::iomgr_engine::ThreadPool::Add

(

const std::function< void()> &

callback

)

Definition at line 112 of file thread_pool.cc.

PostforkChild()

void grpc_event_engine::iomgr_engine::ThreadPool::PostforkChild ( )

overridevirtual

Implements grpc_event_engine::experimental::Forkable.

Definition at line 149 of file thread_pool.cc.

PostforkParent()

void grpc_event_engine::iomgr_engine::ThreadPool::PostforkParent ( )

overridevirtual

Implements grpc_event_engine::experimental::Forkable.

Definition at line 143 of file thread_pool.cc.

PrepareFork()

void grpc_event_engine::iomgr_engine::ThreadPool::PrepareFork ( )

overridevirtual

Implements grpc_event_engine::experimental::Forkable.

Definition at line 133 of file thread_pool.cc.

ReapThreads()

void grpc_event_engine::iomgr_engine::ThreadPool::ReapThreads ( std::vector< Thread * > *  tlist )

staticprivate

Definition at line 97 of file thread_pool.cc.

StartNThreadsLocked()

void grpc_event_engine::iomgr_engine::ThreadPool::StartNThreadsLocked ( int  n ) &

private

Definition at line 90 of file thread_pool.cc.

ThreadFunc()

void grpc_event_engine::iomgr_engine::ThreadPool::ThreadFunc ( )

private

Definition at line 52 of file thread_pool.cc.

Member Data Documentation

callbacks_

std::queue<std::function<void()> > grpc_event_engine::iomgr_engine::ThreadPool::callbacks_

private

Definition at line 70 of file src/core/lib/event_engine/iomgr_engine/thread_pool.h.

cv_

grpc_core::CondVar grpc_event_engine::iomgr_engine::ThreadPool::cv_

private

Definition at line 66 of file src/core/lib/event_engine/iomgr_engine/thread_pool.h.

dead_threads_

std::vector<Thread*> grpc_event_engine::iomgr_engine::ThreadPool::dead_threads_

private

Definition at line 74 of file src/core/lib/event_engine/iomgr_engine/thread_pool.h.

fork_cv_

grpc_core::CondVar grpc_event_engine::iomgr_engine::ThreadPool::fork_cv_

private

Definition at line 68 of file src/core/lib/event_engine/iomgr_engine/thread_pool.h.

forking_

bool grpc_event_engine::iomgr_engine::ThreadPool::forking_

private

Definition at line 75 of file src/core/lib/event_engine/iomgr_engine/thread_pool.h.

mu_

grpc_core::Mutex grpc_event_engine::iomgr_engine::ThreadPool::mu_

private

Definition at line 65 of file src/core/lib/event_engine/iomgr_engine/thread_pool.h.

nthreads_

int grpc_event_engine::iomgr_engine::ThreadPool::nthreads_

private

Definition at line 72 of file src/core/lib/event_engine/iomgr_engine/thread_pool.h.

reserve_threads_

int grpc_event_engine::iomgr_engine::ThreadPool::reserve_threads_

private

Definition at line 71 of file src/core/lib/event_engine/iomgr_engine/thread_pool.h.

shutdown_

bool grpc_event_engine::iomgr_engine::ThreadPool::shutdown_

private

Definition at line 69 of file src/core/lib/event_engine/iomgr_engine/thread_pool.h.

shutdown_cv_

grpc_core::CondVar grpc_event_engine::iomgr_engine::ThreadPool::shutdown_cv_

private

Definition at line 67 of file src/core/lib/event_engine/iomgr_engine/thread_pool.h.

threads_waiting_

int grpc_event_engine::iomgr_engine::ThreadPool::threads_waiting_

private

Definition at line 73 of file src/core/lib/event_engine/iomgr_engine/thread_pool.h.

---

The documentation for this class was generated from the following files:

• src/core/lib/event_engine/iomgr_engine/thread_pool.h
• thread_pool.cc