Search  

---

C:/temp/src/j2k/nto/bak2/MsgThreadTest.cpp

Go to the documentation of this file.

#include <j2k/Fred/Standard.hpp>
#include <j2k/nto/MsgThread.hpp>
#include <j2k/nto/TimerPulse.hpp>
#include <j2k/nto/Message.hpp>

class T1 : public MsgThread
{
public:

  int id;
  pid_t p;

  T1() : MsgThread( "T1" ) 
  { 
    p = pid;
  }

  void run()
  {
    int i = 100;
    while( 1 )
    {
      printf( "1" );
      Message m( i++ );
      send( "T2", m );
      Message m2 = receive( id );

      printf( "[%d|%d]", m.getNumber(), m2.getNumber() );
    }
  }
};

class T2 : public MsgThread
{
public:

  pid_t p;

  T2() : MsgThread( "T2" ) 
  { 
    p = pid;    
  }

  int id;

  
  void run()
  {
    int i = 1000;
    while( 1 )
    {
      printf( "2" );
      Message m( i++ );
      send( "T1", m );
      Message m2 = receive( id );

      printf( "[%d|%d]", m.getNumber(), m2.getNumber() );
    }
  }
};

int main()
{
  T1 a;
  T2 b;

  a.start();
  b.start();

  a.id = (int)b.p;
  b.id = (int)a.p;

  a.join();
  b.join();

  for(;;) { 
   printf( "M" );
   sched_yield();
  } 

return 0;
}

---