#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 |
|
Definition at line 61 of file ThreadPool.cpp. |
|
Definition at line 62 of file ThreadPool.cpp. |
|
Definition at line 457 of file ThreadPool.cpp. |
|
Definition at line 109 of file ThreadPool.cpp. |
|
Definition at line 456 of file ThreadPool.cpp. |
|
Definition at line 108 of file ThreadPool.cpp. |
|
Definition at line 287 of file ThreadPool.cpp. |
|
Definition at line 276 of file ThreadPool.cpp. |
|
Definition at line 576 of file ThreadPool.cpp. |
|
Definition at line 288 of file ThreadPool.cpp. |
|
Definition at line 279 of file ThreadPool.cpp. |
|
Definition at line 280 of file ThreadPool.cpp. |
|
Definition at line 285 of file ThreadPool.cpp. |
|
Definition at line 283 of file ThreadPool.cpp. |
|
Definition at line 286 of file ThreadPool.cpp. |
|
Definition at line 284 of file ThreadPool.cpp. |
|
Definition at line 281 of file ThreadPool.cpp. |
|
Definition at line 454 of file ThreadPool.cpp. |
|
Definition at line 106 of file ThreadPool.cpp. |
|
Definition at line 278 of file ThreadPool.cpp. |