SourceXtractorPlusPlus  0.16
Please provide a description of the project.
MultithreadedMeasurement.h
Go to the documentation of this file.
1 
17 /*
18  * Multithreadedmeasurement.h
19  *
20  * Created on: May 17, 2018
21  * Author: mschefer
22  */
23 
24 #ifndef _SEIMPLEMENTATION_OUTPUT_MULTITHREADEDMEASUREMENT_H_
25 #define _SEIMPLEMENTATION_OUTPUT_MULTITHREADEDMEASUREMENT_H_
26 
27 #include <atomic>
28 #include <thread>
29 #include <mutex>
30 #include <condition_variable>
31 #include <atomic>
35 
36 namespace SourceXtractor {
37 
39 public:
40 
43  unsigned max_queue_size)
44  : m_source_to_row(source_to_row),
45  m_thread_pool(thread_pool),
46  m_group_counter(0),
47  m_input_done(false), m_abort_raised(false), m_semaphore(max_queue_size) {}
48 
49  virtual ~MultithreadedMeasurement();
50 
51  void handleMessage(const std::shared_ptr<SourceGroupInterface>& source_group) override;
52 
53  void startThreads() override;
54  void waitForThreads() override;
55 
56 private:
57  static void outputThreadStatic(MultithreadedMeasurement* measurement);
58  void outputThreadLoop();
59 
63 
65  std::atomic_bool m_input_done, m_abort_raised;
66 
71 };
72 
73 }
74 
75 #endif /* _SEIMPLEMENTATION_OUTPUT_MULTITHREADEDMEASUREMENT_H_ */
std::unique_ptr< std::thread > m_output_thread
void handleMessage(const std::shared_ptr< SourceGroupInterface > &source_group) override
std::list< std::pair< int, std::shared_ptr< SourceGroupInterface > > > m_output_queue
std::shared_ptr< Euclid::ThreadPool > m_thread_pool
MultithreadedMeasurement(SourceToRowConverter source_to_row, const std::shared_ptr< Euclid::ThreadPool > &thread_pool, unsigned max_queue_size)
static void outputThreadStatic(MultithreadedMeasurement *measurement)
The SourceInterface is an abstract "source" that has properties attached to it.