17#ifndef __TBB_concurrent_priority_queue_H
18#define __TBB_concurrent_priority_queue_H
20#define __TBB_concurrent_priority_queue_H_include_area
34#include __TBB_STD_SWAP_HEADER
36#if __TBB_INITIALIZER_LISTS_PRESENT
37 #include <initializer_list>
40#if __TBB_CPP11_IS_COPY_CONSTRUCTIBLE_PRESENT
41 #include <type_traits>
47#if __TBB_CPP11_IS_COPY_CONSTRUCTIBLE_PRESENT
49 struct use_element_copy_constructor {
53 struct use_element_copy_constructor <T,false> {
67template <
typename T,
typename Compare=std::less<T>,
typename A=cache_aligned_allocator<T> >
104 data.reserve(init_capacity);
112 data.reserve(init_capacity);
117 template<
typename InputIterator>
127 template<
typename InputIterator>
136#if __TBB_INITIALIZER_LISTS_PRESENT
185#if __TBB_CPP11_RVALUE_REF_PRESENT
207#if !__TBB_ALLOCATOR_TRAITS_PRESENT
208 if (a != src.data.get_allocator()){
209 data.reserve(src.data.size());
210 data.assign(std::make_move_iterator(src.data.begin()), std::make_move_iterator(src.data.end()));
223#if !__TBB_ALLOCATOR_TRAITS_PRESENT
224 if (
data.get_allocator() != src.data.get_allocator()){
225 vector_t(std::make_move_iterator(src.data.begin()), std::make_move_iterator(src.data.end()),
data.get_allocator()).swap(
data);
237 template<
typename InputIterator>
245#if __TBB_INITIALIZER_LISTS_PRESENT
247 void assign(std::initializer_list<T> il) { this->
assign(il.begin(), il.end()); }
251 this->
assign(il.begin(), il.end());
269#if __TBB_CPP11_IS_COPY_CONSTRUCTIBLE_PRESENT
278#if __TBB_CPP11_RVALUE_REF_PRESENT
288#if __TBB_CPP11_VARIADIC_TEMPLATES_PRESENT
291 template<
typename... Args>
304 op_data.
elem = &elem;
353 cpq->handle_operations(op_list);
385 typedef std::vector<value_type, allocator_type>
vector_t;
493 while (child <
mark) {
501 child = (cur_pos<<1)+1;
503 if (cur_pos !=
data.size()-1)
514 __TBB_ASSERT(
false,
"The type is not copy constructible. Copying push operation is impossible." );
518#if __TBB_CPP17_DEDUCTION_GUIDES_PRESENT
521template<
typename T,
typename... Args>
524 std::conditional_t< (
sizeof...(Args)>0) && !is_allocator_v< pack_element_t<0, Args...> >,
525 pack_element_t<0, Args...>, std::less<T> >,
526 std::conditional_t< (
sizeof...(Args)>0) && is_allocator_v< pack_element_t<
sizeof...(Args)-1, Args...> >,
532template<
typename InputIterator,
533 typename T =
typename std::iterator_traits<InputIterator>::value_type,
535> concurrent_priority_queue(InputIterator, InputIterator, Args...)
536-> internal::priority_queue_t<T, Args...>;
538template<
typename T,
typename CompareOrAllocalor>
539concurrent_priority_queue(std::initializer_list<T> init_list, CompareOrAllocalor)
540-> internal::priority_queue_t<T, CompareOrAllocalor>;
545using interface5::concurrent_priority_queue;
550#undef __TBB_concurrent_priority_queue_H_include_area
#define __TBB_ASSERT(predicate, comment)
No-op version of __TBB_ASSERT.
#define __TBB_STATIC_ASSERT(condition, msg)
#define __TBB_ALLOCATOR_TRAITS_PRESENT
void const char const char int ITT_FORMAT __itt_group_sync x void const char ITT_FORMAT __itt_group_sync s void ITT_FORMAT __itt_group_sync p void ITT_FORMAT p void ITT_FORMAT p no args __itt_suppress_mode_t unsigned int void size_t ITT_FORMAT d void ITT_FORMAT p void ITT_FORMAT p __itt_model_site __itt_model_site_instance ITT_FORMAT p __itt_model_task __itt_model_task_instance ITT_FORMAT p void ITT_FORMAT p void ITT_FORMAT p void size_t ITT_FORMAT d void ITT_FORMAT p const wchar_t ITT_FORMAT s const char ITT_FORMAT s const char ITT_FORMAT s const char ITT_FORMAT s no args void ITT_FORMAT p size_t ITT_FORMAT d no args const wchar_t const wchar_t ITT_FORMAT s __itt_heap_function void size_t int ITT_FORMAT d __itt_heap_function void ITT_FORMAT p __itt_heap_function void void size_t int ITT_FORMAT d no args no args unsigned int ITT_FORMAT u const __itt_domain __itt_id ITT_FORMAT lu const __itt_domain __itt_id __itt_id __itt_string_handle ITT_FORMAT p const __itt_domain __itt_id ITT_FORMAT p const __itt_domain __itt_id __itt_timestamp __itt_timestamp end
void const char const char int ITT_FORMAT __itt_group_sync x void const char ITT_FORMAT __itt_group_sync s void ITT_FORMAT __itt_group_sync p void ITT_FORMAT p void ITT_FORMAT p no args __itt_suppress_mode_t unsigned int void size_t ITT_FORMAT d void ITT_FORMAT p void ITT_FORMAT p __itt_model_site __itt_model_site_instance ITT_FORMAT p __itt_model_task __itt_model_task_instance ITT_FORMAT p void ITT_FORMAT p void ITT_FORMAT p void size_t ITT_FORMAT d void ITT_FORMAT p const wchar_t ITT_FORMAT s const char ITT_FORMAT s const char ITT_FORMAT s const char ITT_FORMAT s no args void ITT_FORMAT p size_t ITT_FORMAT d no args const wchar_t const wchar_t ITT_FORMAT s __itt_heap_function void size_t int ITT_FORMAT d __itt_heap_function void ITT_FORMAT p __itt_heap_function void void size_t int ITT_FORMAT d no args no args unsigned int ITT_FORMAT u const __itt_domain __itt_id ITT_FORMAT lu const __itt_domain __itt_id __itt_id __itt_string_handle ITT_FORMAT p const __itt_domain __itt_id ITT_FORMAT p const __itt_domain __itt_id __itt_timestamp begin
void const char const char int ITT_FORMAT __itt_group_sync x void const char ITT_FORMAT __itt_group_sync s void ITT_FORMAT __itt_group_sync p void ITT_FORMAT p void ITT_FORMAT p no args __itt_suppress_mode_t unsigned int void size_t ITT_FORMAT d void ITT_FORMAT p void ITT_FORMAT p __itt_model_site __itt_model_site_instance ITT_FORMAT p __itt_model_task __itt_model_task_instance ITT_FORMAT p void ITT_FORMAT p void ITT_FORMAT p void size_t ITT_FORMAT d void ITT_FORMAT p const wchar_t ITT_FORMAT s const char ITT_FORMAT s const char ITT_FORMAT s const char ITT_FORMAT s no args void ITT_FORMAT p size_t ITT_FORMAT d no args const wchar_t const wchar_t ITT_FORMAT s __itt_heap_function void size_t int ITT_FORMAT d __itt_heap_function void ITT_FORMAT p __itt_heap_function void void size_t int ITT_FORMAT d no args no args unsigned int ITT_FORMAT u const __itt_domain __itt_id ITT_FORMAT lu const __itt_domain __itt_id __itt_id parent
void const char const char int ITT_FORMAT __itt_group_sync x void const char ITT_FORMAT __itt_group_sync s void ITT_FORMAT __itt_group_sync p void ITT_FORMAT p void ITT_FORMAT p no args __itt_suppress_mode_t unsigned int void size_t ITT_FORMAT d void ITT_FORMAT p void ITT_FORMAT p __itt_model_site __itt_model_site_instance ITT_FORMAT p __itt_model_task __itt_model_task_instance ITT_FORMAT p void ITT_FORMAT p void ITT_FORMAT p void size_t ITT_FORMAT d void ITT_FORMAT p const wchar_t ITT_FORMAT s const char ITT_FORMAT s const char ITT_FORMAT s const char ITT_FORMAT s no args void ITT_FORMAT p size_t ITT_FORMAT d no args const wchar_t const wchar_t ITT_FORMAT s __itt_heap_function void size_t int ITT_FORMAT d __itt_heap_function void ITT_FORMAT p __itt_heap_function void void size_t int ITT_FORMAT d no args no args unsigned int ITT_FORMAT u const __itt_domain __itt_id ITT_FORMAT lu const __itt_domain __itt_id __itt_id __itt_string_handle ITT_FORMAT p const __itt_domain __itt_id ITT_FORMAT p const __itt_domain __itt_id __itt_timestamp __itt_timestamp ITT_FORMAT lu const __itt_domain __itt_id __itt_id __itt_string_handle ITT_FORMAT p const __itt_domain ITT_FORMAT p const __itt_domain __itt_string_handle unsigned long long value
const size_t NFS_MaxLineSize
Compile-time constant that is upper bound on cache line/sector size.
void move(tbb_thread &t1, tbb_thread &t2)
Identifiers declared inside namespace internal should never be used directly by client code.
T __TBB_load_with_acquire(const volatile T &location)
void swap(atomic< T > &lhs, atomic< T > &rhs)
void throw_exception(exception_id eid)
Versionless convenience wrapper for throw_exception_v4()
void itt_hide_store_word(T &dst, T src)
void itt_store_word_with_release(tbb::atomic< T > &dst, U src)
T itt_hide_load_word(const T &src)
void call_itt_notify(notify_type, void *)
void __TBB_store_with_release(volatile T &location, V value)
Meets "allocator" requirements of ISO C++ Standard, Section 20.1.5.
tbb::internal::true_type type
Concurrent priority queue.
concurrent_priority_queue(InputIterator begin, InputIterator end, const Compare &c, const allocator_type &a=allocator_type())
[begin,end) constructor
const T & const_reference
Const reference type.
concurrent_priority_queue(InputIterator begin, InputIterator end, const allocator_type &a=allocator_type())
[begin,end) constructor
concurrent_priority_queue(concurrent_priority_queue &&src, const allocator_type &a)
Move constructor with specific allocator.
void push(const_reference elem)
Pushes elem onto the queue, increasing capacity of queue if necessary.
concurrent_priority_queue & operator=(std::initializer_list< T > il)
Assign from std::initializer_list, not thread-safe.
A allocator_type
Allocator type.
void clear()
Clear the queue; not thread-safe.
void push_back_helper(const T &, tbb::internal::false_type)
T value_type
Element type in the queue.
concurrent_priority_queue(const concurrent_priority_queue &src)
Copy constructor.
concurrent_priority_queue(const allocator_type &a=allocator_type())
Constructs a new concurrent_priority_queue with default capacity.
concurrent_priority_queue(size_type init_capacity, const allocator_type &a=allocator_type())
Constructs a new concurrent_priority_queue with init_sz capacity.
concurrent_priority_queue & operator=(const concurrent_priority_queue &src)
Assignment operator.
void push(value_type &&elem)
Pushes elem onto the queue, increasing capacity of queue if necessary.
tbb::internal::aggregator< my_functor_t, cpq_operation > aggregator_t
size_type size() const
Returns the current number of elements contained in the queue.
size_t size_type
Integral type for representing size of the queue.
char padding1[NFS_MaxLineSize - sizeof(aggregator_t)]
Padding added to avoid false sharing.
concurrent_priority_queue(size_type init_capacity, const Compare &c, const allocator_type &a=allocator_type())
Constructs a new concurrent_priority_queue with init_sz capacity.
__TBB_atomic size_type my_size
bool try_pop(reference elem)
Gets a reference to and removes highest priority element.
concurrent_priority_queue(std::initializer_list< T > init_list, const Compare &c, const allocator_type &a=allocator_type())
Constructor from std::initializer_list.
concurrent_priority_queue(const concurrent_priority_queue &src, const allocator_type &a)
Copy constructor with specific allocator.
aggregator_t my_aggregator
void swap(concurrent_priority_queue &q)
Swap this queue with another; not thread-safe.
concurrent_priority_queue(std::initializer_list< T > init_list, const allocator_type &a=allocator_type())
Constructor from std::initializer_list.
concurrent_priority_queue & operator=(concurrent_priority_queue &&src)
Move assignment operator.
void reheap()
Re-heapify after an extraction.
void assign(std::initializer_list< T > il)
Assign the queue from std::initializer_list, not thread-safe.
void heapify()
Merge unsorted elements into heap.
void assign(InputIterator begin, InputIterator end)
Assign the queue from [begin,end) range, not thread-safe.
size_type mark
The point at which unsorted elements begin.
bool empty() const
Returns true if empty, false otherwise.
std::vector< value_type, allocator_type > vector_t
Storage for the heap of elements in queue, plus unheapified elements.
concurrent_priority_queue(const Compare &c, const allocator_type &a=allocator_type())
Constructs a new concurrent_priority_queue with default capacity.
ptrdiff_t difference_type
Difference type for iterator.
T & reference
Reference type.
concurrent_priority_queue(concurrent_priority_queue &&src)
Move constructor.
void emplace(Args &&... args)
Constructs a new element using args as the arguments for its construction and pushes it onto the queu...
void handle_operations(cpq_operation *op_list)
void push_back_helper(const T &t, tbb::internal::true_type)
allocator_type get_allocator() const
Return allocator object.
char padding2[NFS_MaxLineSize -(2 *sizeof(size_type)) - sizeof(Compare)]
Padding added to avoid false sharing.
cpq_operation(operation_type t)
cpq_operation(const_reference e, operation_type t)
my_functor_t(concurrent_priority_queue< T, Compare, A > *cpq_)
concurrent_priority_queue< T, Compare, A > * cpq
void operator()(cpq_operation *op_list)
aggregated_operation base class
uintptr_t status
Zero value means "wait" status, all other values are "user" specified values and are defined into the...
void initialize_handler(handler_type h)
void execute(operation_type *op)