Search  

---

C:/temp/src/j2k/nto/bak2/PCBuffer.hpp

Go to the documentation of this file.

#ifndef PCBuffer_HPP
#define PCBuffer_HPP

class BoundedBuffer;
class Producer;
class Consumer;

#include "Standard.hpp"
#include "Basic_PThread.hpp"
#include "Mutex.hpp"
#include "RWLock.hpp"
#include "Semaphore.hpp"
#include "BoundedBuffer.hpp"
#include "Timer.hpp"

/***********************************************************************
 ***********************************************************************
 ***                                                                 ***
 ***  message:       Notify that a message is now complete           ***
 ***                                                                 ***
 ***  slot:          Is there any available slot left ?              ***
 ***                                                                 ***
 ***  receiver:      Make sure that only one reader is accessing     ***
 ***                 the buffer at any given time.                   ***
 ***                                                                 ***
 ***  sender:        Make sure that only one writer is modifying     ***
 ***                 the buffer at any given time.                   ***
 ***                                                                 ***
 ***********************************************************************
 ***********************************************************************/

Semaphore   message(  0, "message", 10 );
Semaphore   sender(   1, "sender",  11 );
Semaphore   receiver( 1, "slot",    12 );
Semaphore** slot;
static int done = 0;
BoundedBuffer boundedBuffer( BBSIZE );  // Create a buffer

class Producer : public Basic_PThread {
private:
   int    item;
   int    name;
   _uint64 started;
   double elapsed;
   double total;

public:
   Producer( int n = 1, int i = 0 );
   virtual void run();
};  

class Consumer : public Basic_PThread {
private:
   static int item;

   int    name;

   size_t slotno;
   _uint64 started;
   double elapsed;
   double total;

public:
   Consumer( int n = 1 );
   virtual void run();
};  

int Consumer::item = 0;

#endif

---