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)

---

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.

---