OmniSciDB  d2f719934e
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
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.

117  { /*not implemented*/
118  }
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 WindowFunctionContext::compute(), Executor::launchKernels(), ResultSet::ResultSetComparator< BUFFER_ITERATOR_TYPE >::materializeApproxQuantileColumn(), ResultSet::ResultSetComparator< BUFFER_ITERATOR_TYPE >::materializeCountDistinctColumn(), and ResultSet::parallelTop().

114  {
115  threads_.emplace_back(async(std::forward<F>(f)));
116  }
std::vector< future< void > > threads_
future< Result > async(Fn &&fn, Args &&...args)
char * 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 WindowFunctionContext::compute(), Executor::launchKernels(), ResultSet::ResultSetComparator< BUFFER_ITERATOR_TYPE >::materializeApproxQuantileColumn(), ResultSet::ResultSetComparator< BUFFER_ITERATOR_TYPE >::materializeCountDistinctColumn(), and ResultSet::parallelTop().

119  { // TODO task_group_status ?
120  for (auto& child : this->threads_) {
121  child.wait();
122  }
123  }
std::vector< future< void > > threads_

+ 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: