Dash Core Source Documentation (0.16.0.1)

Find detailed information regarding the Dash Core source code.

VectorAggregator< T > Struct Template Reference
+ Collaboration diagram for VectorAggregator< T >:

Public Types

typedef Aggregator< T > AggregatorType
 
typedef std::vector< T > VectorType
 
typedef std::shared_ptr< VectorTypeVectorPtrType
 
typedef std::vector< VectorPtrTypeVectorVectorType
 
typedef std::function< void(const VectorPtrType &agg)> DoneCallback
 

Public Member Functions

 VectorAggregator (const VectorVectorType &_vecs, size_t _start, size_t _count, bool _parallel, ctpl::thread_pool &_workerPool, DoneCallback _doneCallback)
 
void Start ()
 
void CheckDone (const T &agg, size_t idx)
 

Public Attributes

DoneCallback doneCallback
 
const VectorVectorTypevecs
 
size_t start
 
size_t count
 
bool parallel
 
ctpl::thread_poolworkerPool
 
std::atomic< size_t > doneCount
 
VectorPtrType result
 
size_t vecSize
 

Detailed Description

template<typename T>
struct VectorAggregator< T >

Definition at line 333 of file bls_worker.cpp.

Member Typedef Documentation

◆ AggregatorType

template<typename T>
typedef Aggregator<T> VectorAggregator< T >::AggregatorType

Definition at line 334 of file bls_worker.cpp.

◆ DoneCallback

template<typename T>
typedef std::function<void(const VectorPtrType& agg)> VectorAggregator< T >::DoneCallback

Definition at line 338 of file bls_worker.cpp.

◆ VectorPtrType

template<typename T>
typedef std::shared_ptr<VectorType> VectorAggregator< T >::VectorPtrType

Definition at line 336 of file bls_worker.cpp.

◆ VectorType

template<typename T>
typedef std::vector<T> VectorAggregator< T >::VectorType

Definition at line 335 of file bls_worker.cpp.

◆ VectorVectorType

template<typename T>
typedef std::vector<VectorPtrType> VectorAggregator< T >::VectorVectorType

Definition at line 337 of file bls_worker.cpp.

Constructor & Destructor Documentation

◆ VectorAggregator()

template<typename T>
VectorAggregator< T >::VectorAggregator ( const VectorVectorType _vecs,
size_t  _start,
size_t  _count,
bool  _parallel,
ctpl::thread_pool _workerPool,
DoneCallback  _doneCallback 
)
inline

Member Function Documentation

◆ CheckDone()

template<typename T>
void VectorAggregator< T >::CheckDone ( const T &  agg,
size_t  idx 
)
inline

◆ Start()

Member Data Documentation

◆ count

template<typename T>
size_t VectorAggregator< T >::count

Definition at line 343 of file bls_worker.cpp.

Referenced by VectorAggregator< T >::Start().

◆ doneCallback

template<typename T>
DoneCallback VectorAggregator< T >::doneCallback

Definition at line 339 of file bls_worker.cpp.

Referenced by VectorAggregator< T >::CheckDone().

◆ doneCount

template<typename T>
std::atomic<size_t> VectorAggregator< T >::doneCount

◆ parallel

template<typename T>
bool VectorAggregator< T >::parallel

Definition at line 344 of file bls_worker.cpp.

Referenced by VectorAggregator< T >::Start().

◆ result

template<typename T>
VectorPtrType VectorAggregator< T >::result

◆ start

template<typename T>
size_t VectorAggregator< T >::start

Definition at line 342 of file bls_worker.cpp.

Referenced by VectorAggregator< T >::Start().

◆ vecs

template<typename T>
const VectorVectorType& VectorAggregator< T >::vecs

◆ vecSize

template<typename T>
size_t VectorAggregator< T >::vecSize

◆ workerPool

template<typename T>
ctpl::thread_pool& VectorAggregator< T >::workerPool

Definition at line 345 of file bls_worker.cpp.

Referenced by VectorAggregator< T >::Start().


The documentation for this struct was generated from the following file:
Released under the MIT license