ThreadPool.cpp File Reference

#include "blocxx/BLOCXX_config.h"
#include "blocxx/ThreadPool.hpp"
#include "blocxx/Array.hpp"
#include "blocxx/Thread.hpp"
#include "blocxx/NonRecursiveMutex.hpp"
#include "blocxx/NonRecursiveMutexLock.hpp"
#include "blocxx/Condition.hpp"
#include "blocxx/Format.hpp"
#include "blocxx/Mutex.hpp"
#include "blocxx/MutexLock.hpp"
#include "blocxx/NullLogger.hpp"
#include <deque>

Go to the source code of this file.

Namespaces
namespace	BLOCXX_NAMESPACE
Classes
class	BLOCXX_NAMESPACE::ThreadPoolImpl
Defines
#define	BLOCXX_POOL_LOG_DEBUG(logger, arg)   do { if ((logger)) BLOCXX_LOG_DEBUG(logger, m_poolName + ": " + arg); } while (0)
#define	BLOCXX_POOL_LOG_FATAL_ERROR(logger, arg)   do { if ((logger)) BLOCXX_LOG_FATAL_ERROR(logger, m_poolName + ": " + arg); } while (0)
Functions
void	BLOCXX_NAMESPACE::runRunnable (const RunnableRef &work)
Variables
FixedSizePoolImpl *	m_thePool
Mutex	m_guard
RunnableRef	m_currentRunnable
UInt32	m_maxQueueSize
Array< ThreadRef >	m_threads
std::deque< RunnableRef >	m_queue
bool	m_queueClosed
bool	m_shutdown
NonRecursiveMutex	m_queueLock
Condition	m_queueNotFull
Condition	m_queueEmpty
Condition	m_queueNotEmpty
LoggerRef	m_logger
String	m_poolName
DynamicSizePoolImpl *	m_thePool
Mutex	m_guard
RunnableRef	m_currentRunnable
UInt32	m_maxThreads

---

Define Documentation

#define BLOCXX_POOL_LOG_DEBUG (  logger, arg   )     do { if ((logger)) BLOCXX_LOG_DEBUG(logger, m_poolName + ": " + arg); } while (0)

Definition at line 61 of file ThreadPool.cpp.

#define BLOCXX_POOL_LOG_FATAL_ERROR (  logger, arg   )     do { if ((logger)) BLOCXX_LOG_FATAL_ERROR(logger, m_poolName + ": " + arg); } while (0)

Definition at line 62 of file ThreadPool.cpp.

---

Variable Documentation

RunnableRef m_currentRunnable

Definition at line 457 of file ThreadPool.cpp.

RunnableRef m_currentRunnable

Definition at line 109 of file ThreadPool.cpp.

Mutex m_guard

Definition at line 456 of file ThreadPool.cpp.

Mutex m_guard

Definition at line 108 of file ThreadPool.cpp.

LoggerRef m_logger

Definition at line 287 of file ThreadPool.cpp.

UInt32 m_maxQueueSize

Definition at line 276 of file ThreadPool.cpp.

UInt32 m_maxThreads

Definition at line 576 of file ThreadPool.cpp.

String m_poolName

Definition at line 288 of file ThreadPool.cpp.

std::deque<RunnableRef> m_queue

Definition at line 279 of file ThreadPool.cpp.

bool m_queueClosed

Definition at line 280 of file ThreadPool.cpp.

Condition m_queueEmpty

Definition at line 285 of file ThreadPool.cpp.

NonRecursiveMutex m_queueLock

Definition at line 283 of file ThreadPool.cpp.

Condition m_queueNotEmpty

Definition at line 286 of file ThreadPool.cpp.

Condition m_queueNotFull

Definition at line 284 of file ThreadPool.cpp.

bool m_shutdown

Definition at line 281 of file ThreadPool.cpp.

DynamicSizePoolImpl* m_thePool

Definition at line 454 of file ThreadPool.cpp.

FixedSizePoolImpl* m_thePool

Definition at line 106 of file ThreadPool.cpp.

Array<ThreadRef> m_threads

Definition at line 278 of file ThreadPool.cpp.

---