JACOUSTICS::JFremantle Class Reference

Thread pool for global fits. More...

#include <JFremantle_t.hh>

Public Types
typedef JLANG::JObjectOutput < JSuperEvt >	output_type

Public Member Functions
	JFremantle (const JGeometry &geometry, const JSoundVelocity &velocity, const JFitParameters &parameters, const size_t ns)
	Constructor. More...
	~JFremantle ()
	Destructor. More...
size_t	backlog ()
	Get number of pending data. More...
void	enqueue (data_type &data)
	Queue data. More...

Static Public Attributes
static std::string	oid = ""
	detector identifier More...
static JTOOLS::JQuantile	Q
	chi2/NDF More...
static output_type *	output = NULL
	optional output More...

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

Detailed Description

Thread pool for global fits.

Definition at line 34 of file JFremantle_t.hh.

Member Typedef Documentation

typedef JLANG::JObjectOutput<JSuperEvt> JACOUSTICS::JFremantle::output_type

Definition at line 168 of file JFremantle_t.hh.

Constructor & Destructor Documentation

JACOUSTICS::JFremantle::JFremantle ( const JGeometry &  geometry, const JSoundVelocity &  velocity, const JFitParameters &  parameters, const size_t  ns  )

inline

Constructor.

Parameters

geometry	detector geometry
velocity	sound velocity
parameters	parameters
ns	number of threads

Definition at line 44 of file JFremantle_t.hh.

                                          :
      stop(false)
    {
      using namespace std;
      using namespace JPP;

      Q.reset();

      for (size_t i = 0; i < ns; ++i) {

        thread worker([this, geometry, velocity, parameters]() {

          data_type data;

          for (JGlobalfit katoomba(geometry, velocity, parameters); ; ) {
          
            {
              unique_lock<mutex> lock(in);

              cv.wait(lock, [this]() { return stop || !input.empty(); });

              if (stop && input.empty()) {
                return;
              }

              data.swap(input.front());

              input.pop();
            }

            const auto result = katoomba(data.begin(), data.end());

            if (result.chi2 / result.ndf <= katoomba.parameters.chi2perNDF) {

              {
                unique_lock<mutex> lock(out);

                Q.put(result.chi2 / result.ndf);

                if (JFremantle::output != NULL) {
                  JFremantle::output->put(getSuperEvt(JHead(JFremantle::oid,
                                                            result.getTimeRange(),
                                                            data  .size(),
                                                            result.size(),
                                                            result.value.getN(),
                                                            result.ndf,
                                                            result.chi2),
                                                      result.value,
                                                      result.begin,
                                                      result.end));
                }
              }
            }
          }
        });

        workers.emplace_back(move(worker));
      }
    }

JACOUSTICS::JFremantle::~JFremantle ( )

inline

Destructor.

Definition at line 111 of file JFremantle_t.hh.

    {
      using namespace std;

      {
        unique_lock<mutex> lock(in);

        stop = true;
      }
      
      cv.notify_all();

      for (auto& worker : workers) {
        worker.join();
      }
    }

Member Function Documentation

size_t JACOUSTICS::JFremantle::backlog ( )

inline

Get number of pending data.

Returns

number of pending data

Definition at line 134 of file JFremantle_t.hh.

    {
      using namespace std;

      {
        unique_lock<mutex> lock(in);

        return input.size();
      }
    }

void JACOUSTICS::JFremantle::enqueue ( data_type &  data )

inline

Queue data.

Parameters

data

data

Definition at line 151 of file JFremantle_t.hh.

    {
      using namespace std;
    
      {
        unique_lock<mutex> lock(in);

        if (stop) {
          throw runtime_error("The thread pool has been stopped.");
        }

        input.emplace(move(data));
      }

      cv.notify_one();
    }

Member Data Documentation

std::string JACOUSTICS::JFremantle::oid = ""

static

detector identifier

Definition at line 170 of file JFremantle_t.hh.

JTOOLS::JQuantile JACOUSTICS::JFremantle::Q

static

chi2/NDF

Definition at line 171 of file JFremantle_t.hh.

JFremantle::output_type * JACOUSTICS::JFremantle::output = NULL

static

optional output

Definition at line 172 of file JFremantle_t.hh.

std::vector<std::thread> JACOUSTICS::JFremantle::workers

private

Definition at line 175 of file JFremantle_t.hh.

std::queue<data_type> JACOUSTICS::JFremantle::input

private

Definition at line 176 of file JFremantle_t.hh.

std::mutex JACOUSTICS::JFremantle::in

private

Definition at line 177 of file JFremantle_t.hh.

std::mutex JACOUSTICS::JFremantle::out

private

Definition at line 178 of file JFremantle_t.hh.

std::condition_variable JACOUSTICS::JFremantle::cv

private

Definition at line 179 of file JFremantle_t.hh.

bool JACOUSTICS::JFremantle::stop

private

Definition at line 180 of file JFremantle_t.hh.

---

The documentation for this class was generated from the following files:

• JFremantle_t.hh
• JFremantle_t.cc