#include <acsRequest.h>
Public Member Functions | |
virtual int | svc (void) |
int | enqueue (ACE_Method_Request *request) |
void | shutdown () |
Static Public Member Functions | |
static void | configure (const char *processName, LoggingProxy *log, int threads) |
static ACE_CString | getProcessName () |
static AsyncRequestThreadPool * | getInstance () |
static void | destroy () |
Private Member Functions | |
AsyncRequestThreadPool (int n_threads=1) | |
Private Attributes | |
ACE_Activation_Queue | activation_queue_ |
int | m_threads |
Static Private Attributes | |
static ACE_Thread_Mutex | mutex_ |
static int | conf_threads |
static ACE_CString | process_name |
static LoggingProxy * | logger |
static AsyncRequestThreadPool * | instance_ |
AsyncRequestThreadPool::AsyncRequestThreadPool | ( | int | n_threads = 1 |
) | [private] |
static void AsyncRequestThreadPool::configure | ( | const char * | processName, | |
LoggingProxy * | log, | |||
int | threads | |||
) | [inline, static] |
Referenced by acsDaemonImpl< T >::acsDaemonImpl().
static void AsyncRequestThreadPool::destroy | ( | void | ) | [inline, static] |
Referenced by ACSDaemonServiceImpl< T >::shutdown().
int AsyncRequestThreadPool::enqueue | ( | ACE_Method_Request * | request | ) |
static AsyncRequestThreadPool* AsyncRequestThreadPool::getInstance | ( | ) | [inline, static] |
static ACE_CString AsyncRequestThreadPool::getProcessName | ( | ) | [inline, static] |
void AsyncRequestThreadPool::shutdown | ( | ) |
virtual int AsyncRequestThreadPool::svc | ( | void | ) | [virtual] |
ACE_Activation_Queue AsyncRequestThreadPool::activation_queue_ [private] |
int AsyncRequestThreadPool::conf_threads [static, private] |
AsyncRequestThreadPool* AsyncRequestThreadPool::instance_ [static, private] |
LoggingProxy* AsyncRequestThreadPool::logger [static, private] |
int AsyncRequestThreadPool::m_threads [private] |
ACE_Thread_Mutex AsyncRequestThreadPool::mutex_ [static, private] |
ACE_CString AsyncRequestThreadPool::process_name [static, private] |