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, const int option)
	Constructor.
	~JPerth ()
	Destructor.

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 162 of file JPerth.cc.

Constructor & Destructor Documentation

JPerth()

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

inline

Constructor.

Parameters

storage	storage for PDFs
data	data
ns	number of threads
option	option

Definition at line 171 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, option]() {
 
          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();
 
              // 2 => evaluation of the derivative of the chi2 to each fit parameter.
 
              if (option != 2 || evt->status) {
                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;
            }
 
            if (!data.empty()) {
 
              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 249 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 266 of file JPerth.cc.

workers

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

private

Definition at line 269 of file JPerth.cc.

input

input_type JRECONSTRUCTION::JPerth::input

private

Definition at line 270 of file JPerth.cc.

in

std::mutex JRECONSTRUCTION::JPerth::in

private

Definition at line 271 of file JPerth.cc.

out

std::mutex JRECONSTRUCTION::JPerth::out

private

Definition at line 272 of file JPerth.cc.

cv

std::condition_variable JRECONSTRUCTION::JPerth::cv

private

Definition at line 273 of file JPerth.cc.

stop

bool JRECONSTRUCTION::JPerth::stop

private

Definition at line 274 of file JPerth.cc.

---

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

• JPerth.cc