#include <libmythbase/mthreadpool.h>

Collaboration diagram for MThreadPool:

Public Member Functions
	MThreadPool (const QString &name)

	~MThreadPool ()

	MThreadPool (const MThreadPool &)=delete

MThreadPool &	operator= (const MThreadPool &)=delete

void	Stop (void)

void	DeletePoolThreads (void)

void	start (QRunnable *runnable, const QString &debugName, int priority=0)

bool	tryStart (QRunnable *runnable, const QString &debugName)

void	startReserved (QRunnable *runnable, const QString &debugName, std::chrono::milliseconds waitForAvailMS=0ms)

std::chrono::milliseconds	expiryTimeout (void) const

void	setExpiryTimeout (std::chrono::milliseconds expiryTimeout)

int	maxThreadCount (void) const

void	setMaxThreadCount (int maxThreadCount)

int	activeThreadCount (void) const

void	waitForDone (void)

Static Public Member Functions
static MThreadPool *	globalInstance (void)

static void	StopAllPools (void)

static void	ShutdownAllPools (void)

Private Member Functions
bool	TryStartInternal (QRunnable *runnable, const QString &debugName, bool reserved)

void	NotifyAvailable (MPoolThread *thread)

void	NotifyDone (MPoolThread *thread)

void	ReleaseThread (void)

Private Attributes
MThreadPoolPrivate *	m_priv {nullptr}

Friends
class	MPoolThread

Detailed Description

Definition at line 18 of file mthreadpool.h.

Constructor & Destructor Documentation

◆ MThreadPool() [1/2]

MThreadPool::MThreadPool ( const QString & name )

explicit

Definition at line 248 of file mthreadpool.cpp.

Referenced by globalInstance().

◆ ~MThreadPool()

MThreadPool::~MThreadPool ( )

Definition at line 255 of file mthreadpool.cpp.

◆ MThreadPool() [2/2]

MThreadPool::MThreadPool ( const MThreadPool & )

delete

Member Function Documentation

◆ operator=()

MThreadPool& MThreadPool::operator= ( const MThreadPool & )

delete

◆ Stop()

void MThreadPool::Stop ( void )

Definition at line 267 of file mthreadpool.cpp.

Referenced by MainServer::Stop(), HttpServer::~HttpServer(), ~MThreadPool(), MythSocketManager::~MythSocketManager(), and WebSocketServer::~WebSocketServer().

◆ DeletePoolThreads()

void MThreadPool::DeletePoolThreads ( void )

Definition at line 280 of file mthreadpool.cpp.

Referenced by ~MThreadPool().

◆ globalInstance()

MThreadPool * MThreadPool::globalInstance ( void )

static

Definition at line 307 of file mthreadpool.cpp.

Referenced by ThemeChooser::customEvent(), MythSystemEventHandler::customEvent(), MythDownloadManager::downloadRemoteFile(), ImageHandler< ImageDbSg >::HandleGetMetadata(), MainServer::HandleMoveFile(), MainServer::HandleQueryFreeSpace(), MainServer::HandleQueryFreeSpaceSummary(), ProgramInfoUpdater::insert(), MythScreenType::LoadInBackground(), TextSubtitleParser::LoadSubtitles(), MainServer::MainServer(), MythCommFlagPlayer::RebuildSeekTable(), BackendConnectionManager::ReconnectToBackend(), EditMetadataCommon::saveAll(), MusicData::scanMusic(), ProgramInfoCache::ScheduleLoad(), MythCoreContext::SendEvent(), MythCoreContext::SendMessage(), MConcurrent::RunFunctionTask::start(), DeleteThread::start(), TruncateThread::start(), HTTPLiveStream::StartStream(), Transcode::TranscodeFile(), MusicPlayer::updateVolatileMetadata(), and MythContext::~MythContext().

◆ StopAllPools()

void MThreadPool::StopAllPools ( void )

static

Definition at line 315 of file mthreadpool.cpp.

Referenced by MythCoreContextPrivate::~MythCoreContextPrivate().

◆ ShutdownAllPools()

void MThreadPool::ShutdownAllPools ( void )

static

Definition at line 326 of file mthreadpool.cpp.

Referenced by MythCoreContextPrivate::~MythCoreContextPrivate().

◆ start()

void MThreadPool::start	(	QRunnable *	runnable,
		const QString &	debugName,
		int	priority = `0`
	)

◆ tryStart()

bool MThreadPool::tryStart	(	QRunnable *	runnable,
		const QString &	debugName
	)

Definition at line 383 of file mthreadpool.cpp.

◆ startReserved()

void MThreadPool::startReserved	(	QRunnable *	runnable,
		const QString &	debugName,
		std::chrono::milliseconds	waitForAvailMS = `0ms`
	)

Definition at line 361 of file mthreadpool.cpp.

Referenced by MythSystemEventHandler::customEvent(), MainServer::HandleQueryFreeSpace(), MainServer::HandleQueryFreeSpaceSummary(), MainServer::MainServer(), WebSocketServer::newTcpConnection(), HttpServer::newTcpConnection(), MythSocketManager::readyRead(), MainServer::readyRead(), DeleteThread::start(), and HTTPLiveStream::StartStream().

◆ expiryTimeout()

std::chrono::milliseconds MThreadPool::expiryTimeout ( void ) const

Definition at line 500 of file mthreadpool.cpp.

Referenced by setExpiryTimeout().

◆ setExpiryTimeout()

void MThreadPool::setExpiryTimeout ( std::chrono::milliseconds expiryTimeout )

Definition at line 506 of file mthreadpool.cpp.

◆ maxThreadCount()

int MThreadPool::maxThreadCount ( void ) const

Definition at line 512 of file mthreadpool.cpp.

Referenced by HttpServer::HttpServer(), setMaxThreadCount(), and WebSocketServer::WebSocketServer().

◆ setMaxThreadCount()

void MThreadPool::setMaxThreadCount ( int maxThreadCount )

Definition at line 518 of file mthreadpool.cpp.

Referenced by GuideGrid::GuideGrid(), HttpServer::HttpServer(), MainServer::MainServer(), and WebSocketServer::WebSocketServer().

◆ activeThreadCount()

int MThreadPool::activeThreadCount ( void ) const

Definition at line 524 of file mthreadpool.cpp.

◆ waitForDone()

void MThreadPool::waitForDone ( void )

Definition at line 565 of file mthreadpool.cpp.

Referenced by DeletePoolThreads(), MythContext::~MythContext(), and MythUIImage::~MythUIImage().

◆ TryStartInternal()

bool MThreadPool::TryStartInternal	(	QRunnable *	runnable,
		const QString &	debugName,
		bool	reserved
	)

private

Definition at line 389 of file mthreadpool.cpp.

Referenced by NotifyAvailable(), start(), startReserved(), and tryStart().

◆ NotifyAvailable()

void MThreadPool::NotifyAvailable ( MPoolThread * thread )

private

Definition at line 448 of file mthreadpool.cpp.

Referenced by MPoolThread::run().

◆ NotifyDone()

void MThreadPool::NotifyDone ( MPoolThread * thread )

private

Definition at line 490 of file mthreadpool.cpp.

Referenced by MPoolThread::run().

◆ ReleaseThread()

void MThreadPool::ReleaseThread ( void )

private

Definition at line 545 of file mthreadpool.cpp.

Referenced by MPoolThread::run().

Friends And Related Function Documentation

◆ MPoolThread

friend class MPoolThread

friend

Definition at line 20 of file mthreadpool.h.

Referenced by TryStartInternal().

Member Data Documentation

◆ m_priv

MThreadPoolPrivate* MThreadPool::m_priv {nullptr}

private

Definition at line 57 of file mthreadpool.h.

Referenced by activeThreadCount(), DeletePoolThreads(), expiryTimeout(), maxThreadCount(), NotifyAvailable(), NotifyDone(), ReleaseThread(), setExpiryTimeout(), setMaxThreadCount(), start(), startReserved(), Stop(), tryStart(), TryStartInternal(), waitForDone(), and ~MThreadPool().

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

mythtv/libs/libmythbase/mthreadpool.h
mythtv/libs/libmythbase/mthreadpool.cpp

Public Member Functions

Static Public Member Functions

Private Member Functions

Private Attributes

Friends

Detailed Description

Constructor & Destructor Documentation

◆ MThreadPool() [1/2]

◆ ~MThreadPool()

◆ MThreadPool() [2/2]

Member Function Documentation

◆ operator=()

◆ Stop()

◆ DeletePoolThreads()

◆ globalInstance()

◆ StopAllPools()

◆ ShutdownAllPools()

◆ start()

◆ tryStart()

◆ startReserved()

◆ expiryTimeout()

◆ setExpiryTimeout()

◆ maxThreadCount()

◆ setMaxThreadCount()

◆ activeThreadCount()

◆ waitForDone()

◆ TryStartInternal()

◆ NotifyAvailable()

◆ NotifyDone()

◆ ReleaseThread()

Friends And Related Function Documentation

◆ MPoolThread

Member Data Documentation

◆ m_priv