OW_ThreadPool.cpp File Reference

#include "OW_config.h"
#include "OW_ThreadPool.hpp"
#include "OW_Array.hpp"
#include "OW_Thread.hpp"
#include "OW_NonRecursiveMutex.hpp"
#include "OW_NonRecursiveMutexLock.hpp"
#include "OW_Condition.hpp"
#include "OW_Format.hpp"
#include "OW_Mutex.hpp"
#include "OW_MutexLock.hpp"
#include "OW_NullLogger.hpp"
#include <deque>

Include dependency graph for OW_ThreadPool.cpp:

Go to the source code of this file.

Namespaces
namespace	OW_NAMESPACE
Classes
class	OW_NAMESPACE::ThreadPoolImpl
Defines
#define	OW_POOL_LOG_DEBUG(logger, arg)   do { if ((logger)) OW_LOG_DEBUG(logger, m_poolName + ": " + arg); } while (0)
#define	OW_POOL_LOG_FATAL_ERROR(logger, arg)   do { if ((logger)) OW_LOG_FATAL_ERROR(logger, m_poolName + ": " + arg); } while (0)
Functions
void	OW_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 OW_POOL_LOG_DEBUG (  logger, arg   )     do { if ((logger)) OW_LOG_DEBUG(logger, m_poolName + ": " + arg); } while (0)

Definition at line 59 of file OW_ThreadPool.cpp.

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

Definition at line 60 of file OW_ThreadPool.cpp.

---

Variable Documentation

RunnableRef m_currentRunnable

Definition at line 455 of file OW_ThreadPool.cpp.

RunnableRef m_currentRunnable

Definition at line 107 of file OW_ThreadPool.cpp.

Mutex m_guard

Definition at line 454 of file OW_ThreadPool.cpp.

Mutex m_guard

Definition at line 106 of file OW_ThreadPool.cpp. Referenced by OW_NAMESPACE::AssocDb::getDbLock().

LoggerRef m_logger

Definition at line 285 of file OW_ThreadPool.cpp.

UInt32 m_maxQueueSize

Definition at line 274 of file OW_ThreadPool.cpp.

UInt32 m_maxThreads

Definition at line 574 of file OW_ThreadPool.cpp.

String m_poolName

Definition at line 286 of file OW_ThreadPool.cpp.

std::deque<RunnableRef> m_queue

Definition at line 277 of file OW_ThreadPool.cpp.

bool m_queueClosed

Definition at line 278 of file OW_ThreadPool.cpp.

Condition m_queueEmpty

Definition at line 283 of file OW_ThreadPool.cpp.

NonRecursiveMutex m_queueLock

Definition at line 281 of file OW_ThreadPool.cpp.

Condition m_queueNotEmpty

Definition at line 284 of file OW_ThreadPool.cpp.

Condition m_queueNotFull

Definition at line 282 of file OW_ThreadPool.cpp.

bool m_shutdown

Definition at line 279 of file OW_ThreadPool.cpp.

DynamicSizePoolImpl* m_thePool

Definition at line 452 of file OW_ThreadPool.cpp.

FixedSizePoolImpl* m_thePool

Definition at line 104 of file OW_ThreadPool.cpp.

Array<ThreadRef> m_threads

Definition at line 276 of file OW_ThreadPool.cpp.

---