Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/cameron314/concurrentqueue
/ functions
Functions
5,688 in github.com/cameron314/concurrentqueue
⨍
Functions
5,688
◇
Types & classes
10,761
↓ 2 callers
Method
free_scheduler
benchmarks/tbb/scheduler.cpp:287
↓ 2 callers
Method
get_allocator
return allocator object
benchmarks/tbb/concurrent_hash_map.h:897
↓ 2 callers
Function
get_block_index_index_for_index
concurrentqueue.h:2970
↓ 2 callers
Method
get_item
benchmarks/tbb/internal/_flow_graph_join_impl.h:545
↓ 2 callers
Function
get_or_add_implicit_producer
Only fails (returns nullptr) if memory allocation fails
concurrentqueue.h:3410
↓ 2 callers
Function
get_tick_count
tests/relacy/relacy/relacy/platform.hpp:23
↓ 2 callers
Function
gettimeofday
vxWorks claims to implement gettimeofday in sys/time.h but nevertheless does not provide it! See https://support.windriver.com/olsPortal/faces/mainten
benchmarks/boost/config/platform/vxworks.hpp:293
↓ 2 callers
Method
handle
benchmarks/tbb/concurrent_lru_cache.h:163
↓ 2 callers
Function
handle_operations
benchmarks/tbb/concurrent_priority_queue.h:329
↓ 2 callers
Function
handle_unconstructed_elements
benchmarks/tbb/concurrent_vector.h:86
↓ 2 callers
Function
hash_thread_id
concurrentqueue.h:475
↓ 2 callers
Method
head_unsafe
Useful for traversing the list when there's no contention (e.g. to destroy remaining nodes)
concurrentqueue.h:1535
↓ 2 callers
Function
hsort_array
benchmarks/dlib/sort.h:364
↓ 2 callers
Method
increment_port_count
benchmarks/tbb/internal/_flow_graph_join_impl.h:928
↓ 2 callers
Method
increment_ref_count
Atomically increment reference count and returns its old value. Has acquire semantics */
benchmarks/tbb/task.h:694
↓ 2 callers
Method
init
benchmarks/tbb/concurrent_vector.h:1112
↓ 2 callers
Method
init_stack_info
benchmarks/tbb/scheduler.cpp:175
↓ 2 callers
Method
insert
Not thread safe. Only call from single producer thread. Note: key must *not* be in hash already, and must be exactly one larger than the previously in
tests/relacy/spmchash.cpp:43
↓ 2 callers
Method
internal_acquire_writer
Acquire write lock on the given mutex.
benchmarks/tbb/spin_rw_mutex.cpp:41
↓ 2 callers
Method
internal_add_built_predecessor
override*/
benchmarks/tbb/flow_graph.h:1921
↓ 2 callers
Function
internal_assign_range
benchmarks/tbb/concurrent_vector.h:1061
↓ 2 callers
Method
internal_decrement_ref_count
benchmarks/tbb/task.cpp:197
↓ 2 callers
Method
internal_delete_built_predecessor
override*/
benchmarks/tbb/flow_graph.h:1927
↓ 2 callers
Function
internal_distance
TODO: why not use std::distance? Hash APIs
benchmarks/tbb/internal/_concurrent_unordered_impl.h:1241
↓ 2 callers
Method
internal_downgrade
Downgrade writer to a reader
benchmarks/tbb/spin_rw_mutex.cpp:112
↓ 2 callers
Method
internal_push
benchmarks/tbb/concurrent_queue.cpp:376
↓ 2 callers
Method
internal_try_acquire_writer
Try to acquire write lock on the given mutex
benchmarks/tbb/spin_rw_mutex.cpp:127
↓ 2 callers
Method
internal_try_pop
benchmarks/tbb/internal/_concurrent_queue_impl.h:538
↓ 2 callers
Method
internal_upgrade
Upgrade reader to become a writer. Returns whether the upgrade happened without releasing and re-acquiring the lock */
benchmarks/tbb/spin_rw_mutex.cpp:86
↓ 2 callers
Method
is_divisible
True if range is divisible. Unspecified if end()<begin(). */
benchmarks/tbb/blocked_range.h:86
↓ 2 callers
Method
is_idle_state
Indicate whether thread that reads this mailbox is idle.
benchmarks/tbb/mailbox.h:215
↓ 2 callers
Function
is_power_of_two
benchmarks/tbb/tbb_stddef.h:379
↓ 2 callers
Method
is_stolen_task
True if task was stolen from the task pool of another thread.
benchmarks/tbb/task.h:784
↓ 2 callers
Function
isort_array
benchmarks/dlib/sort.h:379
↓ 2 callers
Method
iteration_begin
tests/relacy/relacy/relacy/sync_var.hpp:33
↓ 2 callers
Function
itt_load_pointer_with_acquire_v3
benchmarks/tbb/tbb_main.cpp:273
↓ 2 callers
Method
join
benchmarks/tbb/parallel_reduce.h:324
↓ 2 callers
Method
left
benchmarks/tbb/tbb_stddef.h:230
↓ 2 callers
Method
load
tests/relacy/relacy/relacy/var.hpp:40
↓ 2 callers
Method
local
returns reference to local, discarding exists
benchmarks/tbb/enumerable_thread_specific.h:793
↓ 2 callers
Method
local_spawn
Conceptually, this method should be a member of class scheduler. But doing so would force us to publish class scheduler in the headers. */
benchmarks/tbb/scheduler.cpp:607
↓ 2 callers
Method
lock_count
benchmarks/dlib/threads/rmutex_extension.h:43
↓ 2 callers
Method
lock_shared
tests/relacy/relacy/relacy/stdlib/mutex.hpp:559
↓ 2 callers
Method
lookup
benchmarks/tbb/concurrent_hash_map.h:1037
↓ 2 callers
Function
make_atomic
benchmarks/tbb/atomic.h:527
↓ 2 callers
Method
match
benchmarks/tbb/enumerable_thread_specific.h:79
↓ 2 callers
Function
moodycamel_cq_enqueue
c_api/concurrentqueue.cpp:24
↓ 2 callers
Function
moodycamel_cq_try_dequeue
c_api/concurrentqueue.cpp:29
↓ 2 callers
Method
mutate
tests/relacy/relacy/example/proxy_collector/proxy_collector.cpp:111
↓ 2 callers
Method
native_handle
benchmarks/tbb/mutex.h:202
↓ 2 callers
Method
node_pos
benchmarks/simplelockfree.h:178
↓ 2 callers
Function
normalize_priority
benchmarks/tbb/scheduler_common.h:108
↓ 2 callers
Method
note_affinity
Defined out of line so that compiler does not replicate task's vtable. It's pointless to define it inline anyway, because all call sites to it are
benchmarks/tbb/task.cpp:250
↓ 2 callers
Method
notify_all
tests/relacy/relacy/relacy/stdlib/condition_variable.hpp:266
↓ 2 callers
Method
notify_one
tests/relacy/relacy/example/eventcount/eventcount.cpp:402
↓ 2 callers
Method
notify_one
tests/relacy/relacy/relacy/stdlib/condition_variable.hpp:260
↓ 2 callers
Method
notify_relaxed
tests/relacy/relacy/example/eventcount/eventcount.cpp:440
↓ 2 callers
Method
notify_relaxed
tests/relacy/relacy/example/tbb_eventcount/eventcount.cpp:460
↓ 2 callers
Method
num_threads_in_pool
benchmarks/dlib/threads/thread_pool_extension.h:536
↓ 2 callers
Function
num_workers_active
The number of workers active in the arena.
benchmarks/tbb/arena.h:234
↓ 2 callers
Method
number_of_workers_in_my_arena
benchmarks/tbb/scheduler.h:555
↓ 2 callers
Function
on_signal
tests/fuzztests/fuzztests.cpp:649
↓ 2 callers
Method
operator[]
benchmarks/dlib/stl_checked/std_vector_c.h:93
↓ 2 callers
Method
orphan_offloaded_tasks
benchmarks/tbb/arena.cpp:314
↓ 2 callers
Method
output_allocs
tests/relacy/relacy/relacy/slab_allocator.hpp:95
↓ 2 callers
Function
parallel_do
benchmarks/tbb/parallel_do.h:471
↓ 2 callers
Method
park_current_thread
tests/relacy/relacy/relacy/scheduler.hpp:141
↓ 2 callers
Function
pc_defer
tests/relacy/relacy/test/trash/original.hpp:256
↓ 2 callers
Function
pc_sys_dtor
tests/relacy/relacy/test/trash/original.hpp:283
↓ 2 callers
Function
pdr_defer
tests/relacy/relacy/example/ws_deque2/ws_deque.cpp:120
↓ 2 callers
Method
pop
tests/relacy/relacy/test/jtest/jtest.cpp:30
↓ 2 callers
Method
pop
benchmarks/tbb/internal/_concurrent_queue_impl.h:278
↓ 2 callers
Function
populate_initial_block_list
concurrentqueue.h:3061
↓ 2 callers
Method
post
tests/relacy/relacy/relacy/stdlib/semaphore.hpp:327
↓ 2 callers
Method
prepare_wait
tests/relacy/relacy/relacy/stdlib/semaphore.hpp:360
↓ 2 callers
Function
printBenchmarkNames
benchmarks/benchmarks.cpp:1768
↓ 2 callers
Function
printTests
tests/unittests/unittests.cpp:5142
↓ 2 callers
Method
propagate_chain_reaction
Wake up to two sleeping workers, if there are any sleeping. The call is used to propagate a chain reaction where each thread wakes up two threads,
benchmarks/tbb/private_server.cpp:157
↓ 2 callers
Method
push
tests/relacy/relacy/example/cli_ws_deque/cli_ws_deque.cpp:35
↓ 2 callers
Method
push
tests/relacy/relacy/example/java_ws_deque/java_ws_deque.cpp:35
↓ 2 callers
Method
push
tests/relacy/relacy/example/eventcount/eventcount.cpp:215
↓ 2 callers
Method
push
tests/relacy/relacy/example/tbb_eventcount/eventcount.cpp:218
↓ 2 callers
Method
push
benchmarks/dlib/binary_search_tree/binary_search_tree_kernel_1.h:421
↓ 2 callers
Method
push
benchmarks/tbb/internal/_concurrent_queue_impl.h:230
↓ 2 callers
Method
push_front
benchmarks/tbb/intrusive_list.h:169
↓ 2 callers
Method
put_token
Put a token into the buffer. If task information was placed into buffer, returns true; otherwise returns false, informing the caller to create
benchmarks/tbb/pipeline.cpp:139
↓ 2 callers
Function
rbegin
reverse start iterator
benchmarks/tbb/concurrent_vector.h:961
↓ 2 callers
Method
register_pending_exception
benchmarks/tbb/task_group_context.cpp:465
↓ 2 callers
Method
rehash_bucket
TODO refactor to hash_base
benchmarks/tbb/concurrent_hash_map.h:647
↓ 2 callers
Method
release
Release the port
benchmarks/tbb/internal/_flow_graph_join_impl.h:355
↓ 2 callers
Method
remove
tests/relacy/relacy/example/eventcount/eventcount.cpp:233
↓ 2 callers
Method
remove
tests/relacy/relacy/example/tbb_eventcount/eventcount.cpp:237
↓ 2 callers
Method
remove
benchmarks/tbb/internal/_flow_graph_impl.h:284
↓ 2 callers
Function
remove_edge
benchmarks/tbb/flow_graph.h:3152
↓ 2 callers
Method
remove_predecessor
Remove a predecessor from the node
benchmarks/tbb/flow_graph.h:199
↓ 2 callers
Method
remove_server_ref
benchmarks/tbb/private_server.cpp:171
↓ 2 callers
Function
rend
reverse end iterator
benchmarks/tbb/concurrent_vector.h:963
↓ 2 callers
Function
reown_producers
concurrentqueue.h:3301
↓ 2 callers
Method
reserve
benchmarks/dlib/stl_checked/std_vector_c.h:76
↓ 2 callers
Method
reserve
Prepare enough segments for number of buckets
benchmarks/tbb/concurrent_hash_map.h:292
← previous
next →
701–800 of 5,688, ranked by callers