Types & classes — github.com/carllerche/syncbox

CodeHub MCPcopy Create free account

hub / github.com/carllerche/syncbox / types & classes

Types & classes34 in github.com/carllerche/syncbox

⨍ Functions 111◇ Types & classes 34

↓ 8 callersClassDelay

src/delay_queue.rs:25

↓ 1 callersInterfaceDelayed

A value that should not be used until the delay has expired.

src/delay_queue.rs:9

ClassArrayQueue

A bounded, array-based queue, with compare-and-swap based operations.

src/array_queue.rs:60

InterfaceAtomic

src/atomic.rs:22

src/atomic.rs:185

ClassAtomicState

src/thread_pool.rs:657

src/atomic.rs:129

TODO: Move A -> ToAtomicRepr associated type (blocked rust-lang/rust#20772)

src/atomic.rs:55

InterfaceBoxedTask

src/thread_pool.rs:141

src/thread_pool.rs:548

ClassDelayQueue

An unbounded blocking queue of delayed values. When a value is pushed onto the queue, a delay is included. The value will only be able to be popped of

src/delay_queue.rs:58

src/delay_queue.rs:213

src/delay_queue.rs:62

src/thread_pool.rs:764

ClassLinkedQueue

A queue in which values are contained by a linked list. The current implementation is based on a mutex and two condition variables. It is also mostly

src/linked_queue.rs:12

src/delay_queue.rs:159

src/array_queue.rs:37

src/linked_queue.rs:351

src/linked_queue.rs:372

An interface for queues of elements of type `T`.

ClassQueueInner

A variant of the "two lock queue" algorithm. The putLock gates entry to put (and offer), and has an associated condition for waiting puts. Similarly

src/linked_queue.rs:144

src/thread_pool.rs:120

ClassScheduledThreadPool

A thread pool that can schedule tasks to run after a given delay, or to execute periodically. Delayed tasks do not run before their associated delays,

src/thread_pool.rs:83

src/thread_pool.rs:716

src/array_queue.rs:45

InterfaceSyncQueue

An interface for synchronous queues of elements of type `T`. This extends `Queue` with blocking analogs of `poll` and `offer`. Both `take` and `put`

src/queue.rs:28

A value that can run a unit of work.

InterfaceTaskBox

ClassThreadPool

src/thread_pool.rs:15

ClassThreadPoolInner

## Notes It's important that a worker increments the count before pulling from the queue and never touches the queue after decrementing the worker co

src/thread_pool.rs:161

InterfaceToAtomicRepr

A value that can be stored in an atomic box

src/atomic.rs:42

InterfaceWorkQueue

A queue that can be used to back a thread pool

src/thread_pool.rs:9

src/thread_pool.rs:418