MultiThread.h

//-*-C++-*-
/***************************************************************************
 *
 *   Copyright (C) 2011 by Willem van Straten
 *   Licensed under the Academic Free License version 2.1
 *
 ***************************************************************************/
 
// dspsr/Signal/General/dsp/MultiThread.h
 
#ifndef __dspsr_MultiThread_h
#define __dspsr_MultiThread_h
 
#include "dsp/SingleThread.h"
 
class ThreadContext;
 
namespace dsp {
 
  class MultiThread : public Pipeline
  {
 
  public:
 
    MultiThread ();
    
    ~MultiThread ();
 
    void set_nthread (unsigned);
 
    void set_configuration (SingleThread::Config*);
 
    void set_source (Source*);
 
    Source* get_source ();
 
    void construct ();
 
    void prepare ();
 
    virtual void share ();
 
    void run ();
 
    void finish ();
 
    uint64_t get_minimum_samples () const;
 
  protected:
 
 
    Reference::To<Source> source;
 
    ThreadContext* source_context;
 
    ThreadContext* state_changes;
 
    virtual SingleThread* new_thread () = 0;
 
    std::vector< Reference::To<SingleThread> > threads;
 
    Reference::To<SingleThread::Config> configuration;
 
    std::vector<pthread_t> ids;
 
    static void* thread (void*);
 
    void launch_threads ();
 
    static void wait (SingleThread* fold, SingleThread::State st);
    static void signal (SingleThread* fold, SingleThread::State st);
 
  };
 
}
 
#endif // !defined(__MultiThread_h)