threading_std::task_group Class Reference

#include <threading_std.h>

Public Member Functions
template<typename F >
void	run (F &&f)
void	cancel ()
void	wait ()

Private Attributes
std::vector< future< void > >	threads_

Detailed Description

Definition at line 109 of file threading_std.h.

Member Function Documentation

void threading_std::task_group::cancel ( )

inline

Definition at line 117 of file threading_std.h.

                { /*not implemented*/
  }

template<typename F >

void threading_std::task_group::run ( F &&  f )

inline

Definition at line 114 of file threading_std.h.

References threading_std::async(), and f().

Referenced by Executor::launchKernelsImpl(), ResultSet::ResultSetComparator< BUFFER_ITERATOR_TYPE >::materializeApproxQuantileColumn(), ResultSet::ResultSetComparator< BUFFER_ITERATOR_TYPE >::materializeCountDistinctColumn(), and ResultSet::parallelTop().

                  {
    threads_.emplace_back(async(std::forward<F>(f)));
  }

Here is the call graph for this function:

Here is the caller graph for this function:

void threading_std::task_group::wait ( )

inline

Definition at line 119 of file threading_std.h.

Referenced by Executor::launchKernelsImpl(), ResultSet::ResultSetComparator< BUFFER_ITERATOR_TYPE >::materializeApproxQuantileColumn(), ResultSet::ResultSetComparator< BUFFER_ITERATOR_TYPE >::materializeCountDistinctColumn(), and ResultSet::parallelTop().

              {  // TODO task_group_status ?
    for (auto& child : this->threads_) {
      child.wait();
    }
  }

Here is the caller graph for this function:

Member Data Documentation

std::vector<future<void> > threading_std::task_group::threads_

private

Definition at line 110 of file threading_std.h.

---

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

• /home/jenkins-slave/workspace/core-os-doxygen/Shared/threading_std.h