mkfit::Pool< TT > Class Template Reference

#include <Pool.h>

Public Member Functions
void	clear ()
auto	makeOrGet ()
	Pool ()=default
void	populate (int threads=Config::numThreadsFinder)
size_t	size () const
	~Pool ()

Private Member Functions
void	addBack (TT *x)
TT *	create ()
void	destroy (TT *x)

Private Attributes
tbb::concurrent_queue< TT * >	m_stack

Detailed Description

template<typename TT>
class mkfit::Pool< TT >

Pool for helper objects. All functions are thread safe.

Definition at line 13 of file Pool.h.

Constructor & Destructor Documentation

Pool()

template<typename TT>

mkfit::Pool< TT >::Pool ( )

default

~Pool()

template<typename TT>

mkfit::Pool< TT >::~Pool ( )

inline

Definition at line 17 of file Pool.h.

{ clear(); }

Member Function Documentation

addBack()

template<typename TT>

void mkfit::Pool< TT >::addBack ( TT *  x )

inlineprivate

Definition at line 51 of file Pool.h.

Referenced by mkfit::Pool< mkfit::MkFitter >::makeOrGet().

{ m_stack.push(x); }

clear()

template<typename TT>

void mkfit::Pool< TT >::clear ( void  )

inline

Definition at line 19 of file Pool.h.

Referenced by mkfit::Pool< mkfit::MkFitter >::~Pool().

                 {
      TT *x = nullptr;
      while (m_stack.try_pop(x)) {
        destroy(x);
      }
    }

create()

template<typename TT>

TT* mkfit::Pool< TT >::create ( )

inlineprivate

Definition at line 44 of file Pool.h.

Referenced by mkfit::Pool< mkfit::MkFitter >::makeOrGet(), and mkfit::Pool< mkfit::MkFitter >::populate().

{ return new (Matriplex::aligned_alloc64(sizeof(TT))) TT; };

destroy()

template<typename TT>

void mkfit::Pool< TT >::destroy ( TT *  x )

inlineprivate

Definition at line 46 of file Pool.h.

Referenced by mkfit::Pool< mkfit::MkFitter >::clear().

                        {
      x->~TT();
      std::free(x);
    };

makeOrGet()

template<typename TT>

auto mkfit::Pool< TT >::makeOrGet ( )

inline

Definition at line 34 of file Pool.h.

                     {
      TT *x = nullptr;
      if (not m_stack.try_pop(x)) {
        x = create();
      }
      auto deleter = [this](TT *ptr) { this->addBack(ptr); };
      return std::unique_ptr<TT, decltype(deleter)>(x, std::move(deleter));
    }

populate()

template<typename TT>

void mkfit::Pool< TT >::populate ( int  threads = Config::numThreadsFinder )

inline

Definition at line 28 of file Pool.h.

                                                        {
      for (int i = 0; i < threads; ++i) {
        m_stack.push(create());
      }
    }

size()

template<typename TT>

size_t mkfit::Pool< TT >::size ( void  ) const

inline

Definition at line 26 of file Pool.h.

Referenced by ntupleDataFormat._Collection::__iter__(), and ntupleDataFormat._Collection::__len__().

{ return m_stack.unsafe_size(); }

Member Data Documentation

m_stack

template<typename TT>

tbb::concurrent_queue<TT *> mkfit::Pool< TT >::m_stack

private

Definition at line 53 of file Pool.h.

Referenced by mkfit::Pool< mkfit::MkFitter >::addBack(), mkfit::Pool< mkfit::MkFitter >::clear(), mkfit::Pool< mkfit::MkFitter >::makeOrGet(), mkfit::Pool< mkfit::MkFitter >::populate(), and mkfit::Pool< mkfit::MkFitter >::size().