Search  

---

C:/temp/src/j2k/Deprecated/old_18mar_diff/nto/RWLock_Test.cpp

Go to the documentation of this file.

#include <j2k/Fred/Standard.hpp>
#include <j2k/nto/Basic_PThread.hpp>
#include <j2k/nto/Mutex.hpp>
#include <j2k/nto/RWLock.hpp>

#define MAX  100000

RWLock r;
long p = 100;

class Fred : public Basic_PThread 
{
public:
   Fred( char* n = ".", char c1 = '*', char c2 = '*' ) : Basic_PThread(), 
   s( n ), k1( c1 ), k2( c2 ) { } 

   virtual void run() {
   for(;;) {
           printf(",");
           r.write();
           p += s[0];
           printf( "%c", k1 );
           printf( "Write:%s", s );
           printf( "%c", k2 );
           printf(",");
           sched_yield();
           r.releaseWrite();
   }
   } 

   char* s;
   char  k1;
   char  k2;
};

class Reader : public Basic_PThread 
{
public:
   Reader( char* n = ".", char c1 = '*', char c2 = '*' ) : Basic_PThread(), 
   s( n ), k1( c1 ), k2( c2 ) { } 

   virtual void run() {
   for(;;) {
           printf(",");
           r.read();
           printf( "%c", k1 );
           printf( "Read:%s", s );
           printf( "%c", k2 );
           printf(",");
           sched_yield();
           r.releaseRead();
   }
   } 

   char* s;
   char  k1;
   char  k2;
};


int main( int argc = 0, char* argv[] = NULL) 
{

  // Verify that the Critical Section inside the [CS] (CS) {CS} respectively
  // is not interrupted. 
  // i.e. Simple Mutual exclusion test.

  // Example: if you see [( ]) or [()] or ([{]}) or anything alike then the code is not working.
  // Perhaps, if you see [](){} or anyother combination, then it works just fine!

  Fred* t1 = new Fred( "0",  '[', ']' );
  Fred* t2 = new Fred( "1",  '(', ')' );
  Fred* t3 = new Fred( "2",  '{', '}' );

  Reader* r1 = new Reader( "3",  '[', ']' );
  Reader* r2 = new Reader( "4",  '(', ')' );
  Reader* r3 = new Reader( "5",  '{', '}' );

  t1->start();
  t2->start();
  t3->start();

  r1->start();
  r2->start();
  r3->start();

  printf("t1-2-3 started.\n\n");

  int max = MAX;

  if ( argc > 1 ) 
  {
    printf("max = %s, %d", argv[1], argc );
    max = atoi( argv[1] );
    if ( max < 10 ) max = MAX;
  } 

  for( int i = 0; i < max; i++ ) { 
   printf( "." );

//   sched_yield();
  }

  return 0;
}

---