/////////////////////////////////////////////////////////////////////////////////////////////////////////////////
//// This example is from the ACE Programmers Guide.
//// Chapter: "The Reactor" (Event Management)
//// For details please see the guide at
//// http://www.cs.wustl.edu/~schmidt/ACE.html
//// AUTHOR: Umar Syyid (usyyid@hns.com)
//// and Ambreen Ilyas (ambreen@bitsmart.com)
/////////////////////////////////////////////////////////////////////////////////////////////////////////////

//Example 5
#include "ace/Reactor.h"
#include "ace/Event_Handler.h"
#include "ace/Synch_T.h"
#include "ace/Thread_Manager.h"

class My_Handler: public ACE_Event_Handler{
public:
//Start the event handling process.
My_Handler(){
ACE_DEBUG((LM_DEBUG,"Got open\n"));
activate_threads();
ACE_Reactor::instance()->max_notify_iterations(5);
return 0;
}

//Spawn a separate thread so that it notifies the reactor
void activate_threads(){
ACE_Thread_Manager::instance()
->spawn((ACE_THR_FUNC)svc_start,(void*)this);
}
//Notify the Reactor 10 times.
void svc(){
for(int i=0;i<10;i++)
ACE_Reactor::instance()
->notify(this, ACE_Event_Handler::READ_MASK);
}

//The actual handler which in this case will handle the notifications
int handle_input(int){
ACE_DEBUG((LM_DEBUG, ?Got notification # %d\n?, no));
no++;
return 0;
}

//The entry point for the new thread that is to be created.
static int svc_start(void* arg);
private:
static int no;
};

//Static members
int My_Handler::no=1;
int My_Handler::svc_start(void* arg){
My_Handler *eh= (My_Handler*)arg;
eh->svc();
return -1; //de-register from the reactor
}

int main(int argc, char *argv[]){
ACE_DEBUG((LM_DEBUG,"Starting test \n"));
My_Handler handler;

while(1){
ACE_Reactor::instance()->handle_events();
sleep(3);
}
}
Next Example