csv_threaded_stream_parser.hpp

#ifndef HAVE_TOM__CSV_THREADED_STREAM_PARSER_HPP
#define HAVE_TOM__CSV_THREADED_STREAM_PARSER_HPP
 
#include <boost/thread/thread.hpp>
#include <tom-util/defines.hpp>
#include <fstream>
#include <tom-util/csv_stream_parser.hpp>
#include <tom-util/shared_list.hpp>
 
namespace tom {
    
  class TOM_UTIL_API csv_threaded_stream_parser : public csv_stream_parser
  {
  public:
 
    csv_threaded_stream_parser( std::ifstream &stream, char delim = ',', char escape = '\\', char quote = '\"' ) : 
      csv_stream_parser(stream, delim, escape, quote ), m_buffer( ), m_runner( this)
    { start(); }
 
    virtual ~csv_threaded_stream_parser() { }
 
    // start!
    void start();
 
    virtual bool
    nextLine();
 
    virtual const_iterator 
    begin() const;
 
    virtual iterator
    begin();
 
    virtual const_iterator
    end() const;
 
    virtual iterator 
    end();
 
    virtual size_t
    size();
 
    virtual const String &
    operator[]( int i );
    
  protected:
    struct exerciser;
    friend struct exerciser;
 
    shared_list < csv_stream_parser::token_vector > m_buffer;
    csv_stream_parser::token_vector m_active_line;
 
    struct exerciser
    {
      exerciser( csv_threaded_stream_parser *parser ) : m_parser(parser){ }
      void operator()();
      csv_threaded_stream_parser *m_parser;
    };
 
    exerciser m_runner;
 
  };
/*
  void
  csv_threaded_stream_parser::start()
  {
    
    boost::thread thrd( m_runner );
 
    //we dont want to join...just  let it run...
    //if they want the data they will get it!
    //thrd.join();  
  }
*/
  /* This is the thread func that keeps on pumping data
   * into the buffer...
   */
/*
  void
  csv_threaded_stream_parser::exerciser::operator()()
  {
    while ( m_parser->csv_stream_parser::nextLine() )
      m_parser->m_buffer.push_back( m_parser->csv_stream_parser::m_tokens );
 
    // indicate we are done writing!
    m_parser->m_buffer.set_read_only();
  }
*/
 
} // end tom namespace
 
#endif