ThreadedIterator.h

// Copyright (C) 2001 Jean-Marc Valin

#ifndef _THREADED_ITERATOR_H_
#define _THREADED_ITERATOR_H_

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

namespace FD {

void * workloop (void *param);

class ThreadedIterator : public Iterator {

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

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

  ThreadedIterator (std::string nodeName, ParameterSet params);
  
  virtual ObjectRef getOutput (int output_id, int count);

  void iterator_lock (){pthread_mutex_lock(&mutex);}

  void iterator_unlock(){pthread_mutex_unlock(&mutex);}
  
  virtual void reset();

  void start_thread();

  void stop_thread();

  virtual void initialize();


  ~ThreadedIterator () {

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

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

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

  bool  m_in_getOutput;

  static const int STATUS_RUNNING;

  static const int STATUS_STOPPED;
  
  void* loop(void *param);

  int rate_per_second;

  int internal_pc;

  volatile int thread_status;


  int status;

  pthread_mutex_t mutex;

  pthread_t work_thread;

};

}//namespace FD
#endif

---