thread_count.h File Reference

#include <algorithm>
#include <thread>

Include dependency graph for thread_count.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Namespaces
	import_export

Functions
int	cpu_threads ()
size_t	import_export::num_import_threads (const int32_t copy_params_threads)

Variables
unsigned	g_cpu_threads_override
size_t	g_max_import_threads

Function Documentation

int cpu_threads ( )

inline

Definition at line 25 of file thread_count.h.

References g_cpu_threads_override.

Referenced by RangeJoinHashTable::approximateTupleCount(), BoundingBoxIntersectJoinHashTable::approximateTupleCount(), BaselineJoinHashTable::approximateTupleCount(), Fragmenter_Namespace::InsertOrderFragmenter::compactRows(), anonymous_namespace{BoundingBoxIntersectJoinHashTable.cpp}::compute_bucket_sizes(), StringDictionary::copyStrings(), CodeGenerator::createInValuesBitmap(), Executor::executeWorkUnitImpl(), anonymous_namespace{ExecutionKernel.cpp}::get_available_cpu_threads_per_task(), anonymous_namespace{RelAlgTranslator.cpp}::get_in_values_expr(), ArrowResultSetConverter::getArrowBatch(), StringDictionary::getEquals(), RelAlgTranslator::getInIntegerSetExpr(), StringDictionary::getLike(), StringDictionary::getRegexpLike(), Fragmenter_Namespace::InsertOrderFragmenter::getVacuumOffsets(), DBHandler::init_executor_resource_mgr(), BaselineJoinHashTableBuilder::initHashTableOnCpu(), PerfectJoinHashTableBuilder::initOneToManyHashTableOnCpu(), PerfectJoinHashTableBuilder::initOneToOneHashTableOnCpu(), QueryMemoryInitializer::initRowGroups(), Executor::launchKernelsImpl(), ColumnFetcher::linearizeVarLenArrayColFrags(), ColumnarResults::materializeAllColumnsGroupBy(), ColumnarResults::materializeAllColumnsThroughIteration(), ColumnarResults::materializeAllLazyColumns(), ResultSet::ResultSetComparator< BUFFER_ITERATOR_TYPE >::materializeApproxQuantileColumn(), ResultSet::ResultSetComparator< BUFFER_ITERATOR_TYPE >::materializeCountDistinctColumn(), ResultSetStorage::moveEntriesToBuffer(), StorageIOFacility::normalized_cpu_threads(), threading_serial::parallel_for(), threading_std::parallel_for(), threading_serial::parallel_reduce(), threading_std::parallel_reduce(), ResultSet::parallelTop(), RelAlgExecutor::prepareLeafExecution(), QueryRunner::QueryRunner::QueryRunner(), ResultSetStorage::reduce(), Executor::setupCaching(), startHeavyDBServer(), synthesize_metadata(), anonymous_namespace{TableArchiver.cpp}::update_or_drop_column_ids_in_table_files(), Fragmenter_Namespace::InsertOrderFragmenter::updateColumn(), and Fragmenter_Namespace::InsertOrderFragmenter::updateColumns().

                         {
  auto ov = g_cpu_threads_override;
  return (ov <= 0) ? std::max(2 * std::thread::hardware_concurrency(), 1U) : ov;
}

Here is the caller graph for this function:

Variable Documentation

unsigned g_cpu_threads_override

Definition at line 19 of file thread_count.cpp.

size_t g_max_import_threads

Definition at line 105 of file Importer.cpp.