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< ThreadRefm_threads
std::deque< RunnableRefm_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.


Generated on Fri Jun 16 15:39:10 2006 for blocxx by  doxygen 1.4.6