ReactorThread.h

Go to the documentation of this file.

////////////////////////////////////////////////////////////////////////////////
/*! \file ReactorThread.h
*  \brief Declares and defines a class that manages threads for an ACE_Reactor.
*  \author $Author: rsharo $
*  \version $Revision: 1.1 $
*  \date    $Date: 2004/04/07 13:45:04 $
*///////////////////////////////////////////////////////////////////////////////
#ifndef REACTOR_THREAD_H
#define REACTOR_THREAD_H

#include "ace/Reactor.h"
#include "ace/Task.h"


//
// A class that encapsulates one or more reactor threads.
// A reactor requires one or more threads to operate.  This class 
// simplifies the spawning and termination of these reactor threads.
class ReactorThread : public ACE_Task_Base
{
public:
        //
        // Constructs a ReactorThread object and spawns threads.
        // Spawns the specified number of threads, all running the reactor's
        // event loop.
        ReactorThread(ACE_Reactor *pReactor = ACE_Reactor::instance(), int numThreads=1)
                : m_pReactor(pReactor)
        {
                this->activate(THR_NEW_LWP | THR_JOINABLE, numThreads);
        }
        
        //
        // Destroys the ReactorThread object and terminates its threads.
        // Commands all the reactor's threads to stop running the reactor's
        // event loop and waits for them to actually terminate.
        ~ReactorThread()
        {
                m_pReactor->end_reactor_event_loop();
                
                this->wait();
        }
        
        //
        // Implementation of ACE_Task_Base::svc().  This method
        // runs the reactor's event loop.
        int svc()
        {
                return m_pReactor->run_reactor_event_loop();
        }

protected:
        ACE_Reactor *m_pReactor;
};



#endif // REACTOR_THREAD_H

---