Concurrency::_Parallel_reduce_forward_executor_helper< _Forward_iterator, _Function, _Default_worker_size, _Default_chunk_size > Struct Template Reference

#include <ppl.h>

Public Types
typedef _Parallel_reduce_fixed_worker< _Forward_iterator, _Function >	_Worker_class

Public Member Functions
	_Parallel_reduce_forward_executor_helper (_Forward_iterator &_First, _Forward_iterator _Last, const _Function &_Func)
	_Parallel_reduce_forward_executor_helper (const _Parallel_reduce_forward_executor_helper &_Other)
void	operator() () const
	~_Parallel_reduce_forward_executor_helper ()

Public Attributes
std::auto_ptr< task_handle< _Worker_class > >	_Workers
int	_Worker_size

Member Typedef Documentation

template<typename _Forward_iterator , typename _Function , int _Default_worker_size, int _Default_chunk_size>

typedef _Parallel_reduce_fixed_worker<_Forward_iterator, _Function> Concurrency::_Parallel_reduce_forward_executor_helper< _Forward_iterator, _Function, _Default_worker_size, _Default_chunk_size >::_Worker_class

Constructor & Destructor Documentation

template<typename _Forward_iterator , typename _Function , int _Default_worker_size, int _Default_chunk_size>

Concurrency::_Parallel_reduce_forward_executor_helper< _Forward_iterator, _Function, _Default_worker_size, _Default_chunk_size >::_Parallel_reduce_forward_executor_helper ( _Forward_iterator &  _First, _Forward_iterator  _Last, const _Function &  _Func  )

inline

                                                                                                                        :
        _Workers(static_cast<task_handle<_Worker_class> *>(Concurrency::Alloc(sizeof(task_handle<_Worker_class>) * _Default_worker_size)))
    {
        _Worker_size = 0;
        while (_Worker_size < _Default_worker_size && _First != _Last)
        {
            // Copy the range _Head
            _Forward_iterator _Head = _First;

            // Read from forward iterator
            for (size_t _I = 0; _I < _Default_chunk_size && _First != _Last; ++_I, ++_First)
            {
                // Body is empty
            }

            // _First will be the end of current chunk
            new (_Workers.get() + _Worker_size++) task_handle<_Worker_class>(_Worker_class(_Head, _First, _Func));
        }
    }

template<typename _Forward_iterator , typename _Function , int _Default_worker_size, int _Default_chunk_size>

Concurrency::_Parallel_reduce_forward_executor_helper< _Forward_iterator, _Function, _Default_worker_size, _Default_chunk_size >::_Parallel_reduce_forward_executor_helper ( const _Parallel_reduce_forward_executor_helper< _Forward_iterator, _Function, _Default_worker_size, _Default_chunk_size > &  _Other )

inline

                                                                                                    :
        _Workers(_Other._Workers), _Worker_size(_Other._Worker_size)
    {
    }

template<typename _Forward_iterator , typename _Function , int _Default_worker_size, int _Default_chunk_size>

Concurrency::_Parallel_reduce_forward_executor_helper< _Forward_iterator, _Function, _Default_worker_size, _Default_chunk_size >::~_Parallel_reduce_forward_executor_helper ( )

inline

    {
        if (_Workers.get())
        {
            for (int _I = 0; _I < _Worker_size; _I++)
            {
                _Workers.get()[_I].~task_handle<_Worker_class>();
            }
            Concurrency::Free(_Workers.release());
        }
    }

Member Function Documentation

template<typename _Forward_iterator , typename _Function , int _Default_worker_size, int _Default_chunk_size>

void Concurrency::_Parallel_reduce_forward_executor_helper< _Forward_iterator, _Function, _Default_worker_size, _Default_chunk_size >::operator() ( ) const

inline

    {
        structured_task_group _Tg;
        for(int _I = 0; _I < _Worker_size; _I++)
        {
            _Tg.run(_Workers.get()[_I]);
        }
        _Tg.wait();
    }

Member Data Documentation

template<typename _Forward_iterator , typename _Function , int _Default_worker_size, int _Default_chunk_size>

int Concurrency::_Parallel_reduce_forward_executor_helper< _Forward_iterator, _Function, _Default_worker_size, _Default_chunk_size >::_Worker_size

template<typename _Forward_iterator , typename _Function , int _Default_worker_size, int _Default_chunk_size>

std::auto_ptr<task_handle<_Worker_class> > Concurrency::_Parallel_reduce_forward_executor_helper< _Forward_iterator, _Function, _Default_worker_size, _Default_chunk_size >::_Workers

mutable

---

The documentation for this struct was generated from the following file:

• VS2013/inc/ppl.h