queue_holder_thread.hpp¶

See Public API for a list of names and headers that are part of the public HPX API.

Defines

QUEUE_HOLDER_THREAD_DEBUG¶

namespace hpx

Functions

static hpx::debug::enable_print<QUEUE_HOLDER_THREAD_DEBUG> hpx::tq_deb("QH_THRD")

namespace threads

namespace policies

Enums

enum [anonymous]¶

Values:

max_thread_count = 1000¶

enum [anonymous]¶

Values:

round_robin_rollover = 1¶

Functions

std::size_t fast_mod(std::size_t const input, std::size_t const ceil)¶

template<typename QueueType> struct queue_holder_thread¶

Public Types

template<> using thread_holder_type = queue_holder_thread<QueueType>¶

template<> using mutex_type = std::mutex¶

typedef std::unique_lock<mutex_type> scoped_lock¶

template<> using thread_heap_type = std::list<thread_id_type, util::internal_allocator<thread_id_type>>¶

template<> using task_description = thread_init_data ¶

template<> using thread_map_type = std::unordered_set<thread_id_type, std::hash<thread_id_type>, std::equal_to<thread_id_type>, util::internal_allocator<thread_id_type>>¶

template<> using terminated_items_type = lockfree_fifo::apply<thread_data*>::type¶

Public Functions

queue_holder_thread(QueueType *bp_queue, QueueType *hp_queue, QueueType *np_queue, QueueType *lp_queue, std::size_t domain, std::size_t queue, std::size_t thread_num, std::size_t owner, const thread_queue_init_parameters &init)¶

~queue_holder_thread()¶

bool owns_bp_queue() const¶

bool owns_hp_queue() const¶

bool owns_np_queue() const¶

bool owns_lp_queue() const¶

std::size_t worker_next(std::size_t const workers) const¶

void schedule_thread(threads::thread_id_ref_type thrd, thread_priority priority, bool other_end = false)¶

bool cleanup_terminated(std::size_t thread_num, bool delete_all)¶

void create_thread(thread_init_data &data, thread_id_ref_type *tid, std::size_t thread_num, error_code &ec)¶

void create_thread_object(threads::thread_id_ref_type &tid, threads::thread_init_data &data)¶

void recycle_thread(thread_id_type tid)¶

void add_to_thread_map(threads::thread_id_type tid)¶

void remove_from_thread_map(threads::thread_id_type tid, bool dealloc)¶

bool get_next_thread_HP(threads::thread_id_ref_type &thrd, bool stealing, bool check_new)¶

bool get_next_thread(threads::thread_id_ref_type &thrd, bool stealing)¶

std::size_t add_new_HP(std::int64_t add_count, thread_holder_type *addfrom, bool stealing)¶

std::size_t add_new(std::int64_t add_count, thread_holder_type *addfrom, bool stealing)¶

std::size_t get_queue_length()¶

std::size_t get_thread_count_staged(thread_priority priority) const¶

std::size_t get_thread_count_pending(thread_priority priority) const¶

std::size_t get_thread_count(thread_schedule_state state = thread_schedule_state::unknown, thread_priority priority = thread_priority::default_) const¶

void destroy_thread(threads::thread_data *thrd, std::size_t thread_num, bool xthread)¶: Destroy the passed thread as it has been terminated.

void abort_all_suspended_threads()¶

bool enumerate_threads(hpx::function<bool(thread_id_type)> const &f, thread_schedule_state state = thread_schedule_state::unknown, ) const¶

void debug_info()¶

void debug_queues(const char *prefix)¶

Public Members

QueueType *const bp_queue_¶

QueueType *const hp_queue_¶

QueueType *const np_queue_¶

QueueType *const lp_queue_¶

const std::size_t domain_index_¶

const std::size_t queue_index_¶

const std::size_t thread_num_¶

const std::size_t owner_mask_¶

util::cache_line_data<mutex_type> thread_map_mtx_¶

thread_heap_type thread_heap_small_¶

thread_heap_type thread_heap_medium_¶

thread_heap_type thread_heap_large_¶

thread_heap_type thread_heap_huge_¶

thread_heap_type thread_heap_nostack_¶

util::cache_line_data<std::tuple<std::size_t, std::size_t>> rollover_counters_¶

thread_map_type thread_map_¶

util::cache_line_data<std::atomic<std::int32_t>> thread_map_count_¶

terminated_items_type terminated_items_¶

util::cache_line_data<std::atomic<std::int32_t>> terminated_items_count_¶

thread_queue_init_parameters parameters_¶

Public Static Functions

static void deallocate(threads::thread_data *p)¶

Public Static Attributes

util::internal_allocator<threads::thread_data> thread_alloc_¶

struct queue_data_print¶

Public Functions

template<> queue_data_print(const queue_holder_thread *q)¶

Public Members

template<> const queue_holder_thread *q_¶

Friends

std::ostream &operator<<(std::ostream &os, const queue_data_print &d)¶

struct queue_mc_print¶

Public Functions

template<> queue_mc_print(const QueueType *const q)¶

Public Members

template<> const QueueType *const q_¶

Friends

std::ostream &operator<<(std::ostream &os, const queue_mc_print &d)¶