Source: data-flow/include/ThreadedIterator.h

// Copyright (C) 2001 Jean-Marc Valin

#ifndef _THREADED_ITERATOR_H_
#define _THREADED_ITERATOR_H_

/**
   The ThreadedIterator class is intended to compute at a defined Rate per second (RPS) 
   its output. It is useful for async computing.
   @author Dominic Letourneau, Jonathan Audet
*/

#include "Iterator.h"
#include <pthread.h>



void * workloop (void *param);

class ThreadedIterator : public Iterator {

  //the thread workloop
  friend void * workloop (void *param);

 public:
  
  //virtual void setExitStatus() {thread_status = STATUS_STOPPED; this->Network::setExitStatus();}

  /** The constructor with a nodeName and parameters */
  ThreadedIterator (string nodeName, ParameterSet params);
  
  /** The getOutput method overloaded from Node */
  virtual ObjectRef getOutput (int output_id, int count);

  /** Locking the thread */
  void iterator_lock (){pthread_mutex_lock(&mutex);}

  /** Unlocking the thread */
  void iterator_unlock(){pthread_mutex_unlock(&mutex);}
  
  /**Resets the node internal values and buffers*/
  virtual void reset();

  /** Starts the working thread */
  void start_thread();

  /** Stops the working thread */
  void stop_thread();

  /** initialize function */
  virtual void initialize();


  /** Destructor */
  ~ThreadedIterator () {

    if (status != STATUS_STOPPED) {
      stop_thread();
    }

    //destroying the mutex
    pthread_mutex_destroy(&mutex);
  }

 private:
  
  /** Default constructor that should not be used*/
 /* ThreadedIterator() 
    :Iterator (string("DUMMY"), new ParameterSet()) {
    throw new NodeException (NULL,"The default constructor should not be called from ThreadedIterator",__FILE__,__LINE__);
  }*/

  bool  m_in_getOutput;

   
  void* loop(void *param);

  int rate_per_second;

  int internal_pc;

  volatile int thread_status;

  static const int STATUS_RUNNING;

  static const int STATUS_STOPPED;

  int status;

  pthread_mutex_t mutex;

  pthread_t work_thread;

};
#endif