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.
	~JFremantle ()
	Destructor.
void	enqueue (input_type &data)
	Queue data.

Static Public Attributes
static int	detid = -1
	detector identifier
static JMATH::JQuantile_t	Q
	chi2/NDF
static bool	squash = false
	squash transmissions in output
static output_type *	output = NULL
	optional output

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 33 of file JFremantle_t.hh.

Member Typedef Documentation

input_type

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

Definition at line 36 of file JFremantle_t.hh.

output_type

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

Definition at line 37 of file JFremantle_t.hh.

Constructor & Destructor Documentation

JFremantle()

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 49 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::detid,
                                                            result.getTimeRange(),
                                                            data  .size(),
                                                            result.size(),
                                                            result.value.getN(),
                                                            result.ndf,
                                                            result.chi2,
                                                            katoomba.gandalf.numberOfIterations),
                                                      result.value,
                                                      result.begin,
                                                      JFremantle::squash ? result.begin : result.end));
                }
              }
            }
          }
        });
 
        workers.emplace_back(std::move(worker));
      }
    }

~JFremantle()

JACOUSTICS::JFremantle::~JFremantle ( )

inline

Destructor.

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

enqueue()

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

inline

Queue data.

Parameters

data

data

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

detid

int JACOUSTICS::JFremantle::detid = -1

static

detector identifier

Definition at line 163 of file JFremantle_t.hh.

Q

JMATH::JQuantile_t JACOUSTICS::JFremantle::Q

static

chi2/NDF

Definition at line 164 of file JFremantle_t.hh.

squash

bool JACOUSTICS::JFremantle::squash = false

static

squash transmissions in output

Definition at line 165 of file JFremantle_t.hh.

output

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

static

optional output

Definition at line 166 of file JFremantle_t.hh.

workers

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

private

Definition at line 169 of file JFremantle_t.hh.

input

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

private

Definition at line 170 of file JFremantle_t.hh.

in

std::mutex JACOUSTICS::JFremantle::in

private

Definition at line 171 of file JFremantle_t.hh.

out

std::mutex JACOUSTICS::JFremantle::out

private

Definition at line 172 of file JFremantle_t.hh.

cv

std::condition_variable JACOUSTICS::JFremantle::cv

private

Definition at line 173 of file JFremantle_t.hh.

cw

std::condition_variable JACOUSTICS::JFremantle::cw

private

Definition at line 174 of file JFremantle_t.hh.

stop

bool JACOUSTICS::JFremantle::stop

private

Definition at line 175 of file JFremantle_t.hh.

backlog

size_t JACOUSTICS::JFremantle::backlog

private

Definition at line 176 of file JFremantle_t.hh.

---

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

• JFremantle_t.hh
• JFremantle_t.cc