JRECONSTRUCTION::JPerth Struct Reference

Thread pool for fits to data. More...

Public Member Functions
	JPerth (const JRegressorStorage_t &storage, const data_type &data, const size_t ns)
	Constructor. More...
	~JPerth ()
	Destructor. More...

Static Public Attributes
static JMATH::JQuantile_t	Q

Private Attributes
std::vector< std::thread >	workers
input_type	input
std::mutex	in
std::mutex	out
std::condition_variable	cv
bool	stop

Detailed Description

Thread pool for fits to data.

Definition at line 138 of file JPerth.cc.

Constructor & Destructor Documentation

JPerth()

JRECONSTRUCTION::JPerth::JPerth ( const JRegressorStorage_t &  storage, const data_type &  data, const size_t  ns  )

inline

Constructor.

Parameters

storage	storage for PDFs
data	data
ns	number of threads

Definition at line 146 of file JPerth.cc.

                                          :
      input(data),
      stop(false)
    {
      using namespace std;
      using namespace JPP;
 
      Q.reset();
 
      for (size_t i = 0; i < ns; ++i) {
 
        thread worker([this, storage]() {
 
          JRegressor_t regressor(storage);
 
          regressor.parameters.resize(5);
 
          regressor.parameters[0] = JLine3Z::pX();
          regressor.parameters[1] = JLine3Z::pY();
          regressor.parameters[2] = JLine3Z::pT();
          regressor.parameters[3] = JLine3Z::pDX();
          regressor.parameters[4] = JLine3Z::pDY();
 
          buffer_type  data;
          JLine3Z      value;
          
          for ( ; ; ) {
 
            {
              unique_lock<mutex> lock(in);
 
              cv.wait(lock, [this]() { return stop || this->input.hasNext(); });
 
              if (stop && !this->input.hasNext()) {
                return;
              }
 
              const event_type* evt = this->input.next();
 
              // re-organise data
 
              data.clear();
 
              for (map_type::const_iterator p = evt->data.begin(); p != evt->data.end(); ++p) {
                copy(p->second.begin(), p->second.end(), back_inserter(data));
              }
              
              value = evt->value;
            }
            
            const double chi2 = regressor(value, data.begin(), data.end());
 
            {
              unique_lock<mutex> lock(out);
 
              Q.put(chi2);
            }
          }
        });
 
        workers.emplace_back(std::move(worker));
      }
    }

~JPerth()

JRECONSTRUCTION::JPerth::~JPerth ( )

inline

Destructor.

Definition at line 216 of file JPerth.cc.

    {
      using namespace std;
 
      {
        unique_lock<mutex> lock(in);
 
        stop = true;
      }
      
      cv.notify_all();
 
      for (auto& worker : workers) {
        worker.join();
      }
    }

Member Data Documentation

Q

JMATH::JQuantile_t JRECONSTRUCTION::JPerth::Q

static

Definition at line 233 of file JPerth.cc.

workers

std::vector<std::thread> JRECONSTRUCTION::JPerth::workers

private

Definition at line 236 of file JPerth.cc.

input

input_type JRECONSTRUCTION::JPerth::input

private

Definition at line 237 of file JPerth.cc.

in

std::mutex JRECONSTRUCTION::JPerth::in

private

Definition at line 238 of file JPerth.cc.

out

std::mutex JRECONSTRUCTION::JPerth::out

private

Definition at line 239 of file JPerth.cc.

cv

std::condition_variable JRECONSTRUCTION::JPerth::cv

private

Definition at line 240 of file JPerth.cc.

stop

bool JRECONSTRUCTION::JPerth::stop

private

Definition at line 241 of file JPerth.cc.

---

The documentation for this struct was generated from the following file:

• JPerth.cc