JACOUSTICS::JFremantle Class Reference

Thread pool for global fits. More...

#include <JFremantle_t.hh>

Public Types
typedef std::vector< JHit >	input_type
typedef JLANG::JObjectOutput < JSuperEvt >	output_type

Public Member Functions
	JFremantle (const JGeometry &geometry, const JSoundVelocity &velocity, const JFitParameters &parameters, const size_t ns, const size_t backlog=std::numeric_limits< size_t >::max())
	Constructor. More...
	~JFremantle ()
	Destructor. More...
void	enqueue (input_type &data)
	Queue data. More...

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

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

Detailed Description

Thread pool for global fits.

Definition at line 31 of file JFremantle_t.hh.

Member Typedef Documentation

typedef std::vector<JHit> JACOUSTICS::JFremantle::input_type

Definition at line 34 of file JFremantle_t.hh.

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

Definition at line 35 of file JFremantle_t.hh.

Constructor & Destructor Documentation

JACOUSTICS::JFremantle::JFremantle ( const JGeometry &  geometry, const JSoundVelocity &  velocity, const JFitParameters &  parameters, const size_t  ns, const size_t  backlog = std::numeric_limits<size_t>::max()  )

inline

Constructor.

Parameters

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

Definition at line 47 of file JFremantle_t.hh.

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

      Q.reset();

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

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

          input_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();
            }

            cw.notify_one();

            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,
                                                      JFremantle::squash ? result.begin : result.end));
                }
              }
            }
          }
        });

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

JACOUSTICS::JFremantle::~JFremantle ( )

inline

Destructor.

Definition at line 118 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

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

inline

Queue data.

Parameters

data

data

Definition at line 141 of file JFremantle_t.hh.

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

        cw.wait(lock, [this]() { return stop || input.size() <= backlog; });

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

        input.emplace(std::move(data));
      }

      cv.notify_one();
    }

Member Data Documentation

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

static

detector identifier

Definition at line 160 of file JFremantle_t.hh.

JQuantile JACOUSTICS::JFremantle::Q

static

chi2/NDF

Definition at line 161 of file JFremantle_t.hh.

bool JACOUSTICS::JFremantle::squash = false

static

squash transmissions in output

Definition at line 162 of file JFremantle_t.hh.

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

static

optional output

Definition at line 163 of file JFremantle_t.hh.

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

private

Definition at line 166 of file JFremantle_t.hh.

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

private

Definition at line 167 of file JFremantle_t.hh.

std::mutex JACOUSTICS::JFremantle::in

private

Definition at line 168 of file JFremantle_t.hh.

std::mutex JACOUSTICS::JFremantle::out

private

Definition at line 169 of file JFremantle_t.hh.

std::condition_variable JACOUSTICS::JFremantle::cv

private

Definition at line 170 of file JFremantle_t.hh.

std::condition_variable JACOUSTICS::JFremantle::cw

private

Definition at line 171 of file JFremantle_t.hh.

bool JACOUSTICS::JFremantle::stop

private

Definition at line 172 of file JFremantle_t.hh.

size_t JACOUSTICS::JFremantle::backlog

private

Definition at line 173 of file JFremantle_t.hh.

---

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

• JFremantle_t.hh
• JFremantle_t.cc