Search  

---

C:/temp/src/j2k/Posix/LockTest.cpp

Go to the documentation of this file.

#include <j2k/Fred/Standard.hpp>
#include <j2k/Fred/Error/JError.cpp>
#include <j2k/445/Posix/Basic_PThread.cpp>
#include <j2k/445/Posix/RWLock.hpp>

#define MAX  100000


RWLock r;
long p = 100;

class Fred : public Basic_PThread 
{
public:
   Fred( char* n = ".", char c = '*' ) : Basic_PThread(), 
   s( n ), k( c ) { } 

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

   char* s;
   char  k;
};

class Reader : public Basic_PThread 
{
public:
   Reader( char* n = ".", char c = '*' ) : Basic_PThread(), 
   s( n ), k( c ) { } 

   virtual void run() {
   for(;;) {
           printf(",");
           r.read();
           printf( "%c", k );
           printf( "Read^%d^", p );
           printf( "%c", k );
           printf(",");
           sched_yield();
           r.releaseRead();
   }
   } 

   char* s;
   char  k;
};


int main( int argc = 0, char* argv[] = NULL) 
{
  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;
}

---