Functions — github.com/carllerche/syncbox

CodeHub MCPcopy Create free account

hub / github.com/carllerche/syncbox / functions

Functions111 in github.com/carllerche/syncbox

⨍ Functions 111◇ Types & classes 34

↓ 51 callersMethodunwrap

Moves the value out of the `Delay<T>`.

src/delay_queue.rs:29

↓ 16 callersMethodclone

src/thread_pool.rs:74

↓ 10 callersMethodoffer

Adds the element `e` to the queue if possible. # Errors A call to `offer` will fail if the queue is full; the provided element `e` is returned in th

src/linked_queue.rs:45

↓ 9 callersMethodload

(&self, order: Ordering)

src/thread_pool.rs:670

↓ 9 callersFunctionsleep_ms

test/test.rs:18

↓ 9 callersFunctionspawn

test/test.rs:13

↓ 9 callersMethodtake

Takes from the queue, blocking until there is an element available. TODO(soon): decide on documenting panic?

src/linked_queue.rs:77

↓ 8 callersMethodlen

Returns the number of elements in the queue.

src/linked_queue.rs:30

↓ 8 callersMethodload

Atomically loads the value from the box with the given ordering

src/atomic.rs:78

↓ 8 callersMethodput

Adds the element `e` to the queue, blocking until it can be added. TODO(soon): decide on documenting panic?

src/linked_queue.rs:61

↓ 7 callersMethodlifecycle

src/thread_pool.rs:729

↓ 7 callersMethodworker_count

src/thread_pool.rs:738

↓ 6 callersMethodrun

↓ 6 callersMethodschedule_ms

(&self, delay: u32, task: T)

src/thread_pool.rs:100

↓ 5 callersMethodadd_worker

(&self, task: Option<T>, core: bool)

src/thread_pool.rs:345

↓ 4 callersMethodas_usize

src/thread_pool.rs:754

↓ 4 callersMethodcompare_and_swap

(&self, expect: State, val: State, order: Ordering)

src/thread_pool.rs:675

↓ 4 callersMethodpush

Adds the element `e` to the queue if possible. # Errors A call to `push` will fail if the queue is full; the provided element `value` is returned in

src/array_queue.rs:78

↓ 4 callersMethodwith_lifecycle

(&self, lifecycle: Lifecycle)

src/thread_pool.rs:733

↓ 3 callersMethodclone

src/array_queue.rs:89

↓ 3 callersMethoddecrement_worker_count

(&self, panicking: bool)

src/thread_pool.rs:521

↓ 3 callersMethodfinish_pop

(&self, mut queue: MutexGuard<'a, BinaryHeap<Entry<T>>>)

src/delay_queue.rs:105

↓ 3 callersFunctionms

test/test_scheduled_pool.rs:76

↓ 3 callersMethodoffer_ms

Adds the element `e` to the queue, blocking for up to `ms` milliseconds. # Errors A call to `offer_ms` will fail if the element cannot be added with

src/linked_queue.rs:55

↓ 3 callersMethodpoll_ms

Takes from the queue, blocking for up to `ms` milliseconds.

src/linked_queue.rs:71

↓ 3 callersMethodrun

(&self, task: T)

src/thread_pool.rs:68

↓ 2 callersMethodcompare_and_swap

Swaps the value in the box if and only if the existing value is equal to `old`.

src/atomic.rs:96

↓ 2 callersMethodfetch_add

(&self, val: u64, order: Ordering)

src/atomic.rs:160

↓ 2 callersMethodfetch_sub

(&self, val: u64, order: Ordering)

src/atomic.rs:165

↓ 2 callersMethodfinalize_threadpool

src/thread_pool.rs:645

↓ 2 callersMethodis_running

src/thread_pool.rs:742

↓ 2 callersMethodis_terminated

src/thread_pool.rs:746

↓ 2 callersMethodpop

Takes from the queue if there is an element available.

src/array_queue.rs:83

↓ 2 callersMethodshutdown

src/thread_pool.rs:50

↓ 2 callersMethodstore

Atomically stores the value from the box with the given ordering

src/atomic.rs:84

↓ 1 callersMethodas_u32

src/thread_pool.rs:750

↓ 1 callersFunctioncheck

test/test_thread_pool.rs:71

↓ 1 callersMethodcmp

(&self, other: &Entry<T>)

src/delay_queue.rs:234

↓ 1 callersMethodcompare_and_dec_worker_count

(&self, expect: State, order: Ordering)

src/thread_pool.rs:685

↓ 1 callersMethodcompare_and_inc_worker_count

(&self, expect: State, order: Ordering)

src/thread_pool.rs:680

↓ 1 callersMethoddelay

src/delay_queue.rs:15

↓ 1 callersFunctiondequeue

(mut head: &mut MutexGuard<NodePtr<T>>)

src/linked_queue.rs:336

↓ 1 callersFunctionenqueue

(node: Node<T>, mut last: &mut MutexGuard<NodePtr<T>>)

src/linked_queue.rs:344

↓ 1 callersMethodfetch_dec_worker_count

(&self, order: Ordering)

src/thread_pool.rs:694

↓ 1 callersMethodfree

src/linked_queue.rs:385

↓ 1 callersMethodget_task

Gets the next task, blocking if necessary. Returns None if the worker should shutdown

src/thread_pool.rs:455

↓ 1 callersMethodis_empty

Returns `true` if the queue contains no elements.

src/linked_queue.rs:35

↓ 1 callersMethodnotify_not_empty

src/linked_queue.rs:321

↓ 1 callersMethodnotify_not_full

Signals a waiting put. Called only from take / poll

src/linked_queue.rs:314

↓ 1 callersMethodoffer

src/delay_queue.rs:132

↓ 1 callersMethodpoll

Takes from the queue if there is an element available.

src/linked_queue.rs:66

↓ 1 callersMethodrun_boxed

src/thread_pool.rs:146

↓ 1 callersMethodrun_boxes

(self: Box<Self>)

↓ 1 callersMethodtransition_to_terminated

(&self, order: Ordering)

src/thread_pool.rs:699

Methodawait_termination

src/thread_pool.rs:62

src/delay_queue.rs:208

src/linked_queue.rs:107

src/thread_pool.rs:125

src/delay_queue.rs:43

src/linked_queue.rs:394

Methodderef_mut

src/delay_queue.rs:49

Methodderef_mut

src/linked_queue.rs:400

src/thread_pool.rs:409

src/linked_queue.rs:330

src/linked_queue.rs:364

(&self, other: &Entry<T>)

src/delay_queue.rs:241

Methodfetch_and

(&self, val: u64, order: Ordering)

src/atomic.rs:170

(&self, val: u64, order: Ordering)

src/atomic.rs:175

Methodfetch_xor

(&self, val: u64, order: Ordering)

src/atomic.rs:180

Methodfixed_size

src/thread_pool.rs:20

src/thread_pool.rs:773

src/delay_queue.rs:127

Methodis_shutdown

src/thread_pool.rs:58

(core_pool_size: u32, maximum_pool_size: u32, work_queue: Q)

src/thread_pool.rs:30

Constructs a new `DelayQueue`.

src/delay_queue.rs:69

Returns a new atomic box

src/atomic.rs:62

Constructs a new, empty `LinkedQueue<T>` with capacity `usize::MAX`.

src/linked_queue.rs:18

src/linked_queue.rs:381

(lifecycle: Lifecycle)

src/thread_pool.rs:725

Methodpartial_cmp

(&self, other: &Entry<T>)

src/delay_queue.rs:228

src/delay_queue.rs:115

Methodpoll_timeout

Takes from the queue, blocking for up to `timeout`.

src/delay_queue.rs:79

Methodprestart_all_core_threads

src/thread_pool.rs:46

Methodprestart_core_thread

src/thread_pool.rs:42

src/delay_queue.rs:202

Methodshutdown_now

src/thread_pool.rs:54

Methodsingle_thread

src/thread_pool.rs:24

Atomically swaps the value in the box with the given ordering

src/atomic.rs:89

src/delay_queue.rs:157

src/array_queue.rs:183

Functiontest_multi_consumer_multi_producer

test/test_linked_queue.rs:98

Functiontest_multi_producer_at_capacity

test/test_linked_queue.rs:192

Functiontest_one_thread_basic

test/test_thread_pool.rs:8

Functiontest_one_thread_one_task

test/test_scheduled_pool.rs:7

Functiontest_one_thread_two_tasks

test/test_scheduled_pool.rs:21

Functiontest_ordering

test/test_delay_queue.rs:5

Functiontest_poll

test/test_delay_queue.rs:18

Functiontest_poll_timeout

test/test_delay_queue.rs:29

Functiontest_queue_with_capacity

test/test_linked_queue.rs:174

Functiontest_single_consumer_multi_producer

test/test_linked_queue.rs:73

next →1–100 of 111, ranked by callers