Module registry 

Re-exports

use std::cell::Cell; 🔒

use std::collections::hash_map::DefaultHasher; 🔒

use std::hash::Hasher; 🔒

use std::sync::atomic::AtomicUsize; 🔒

use std::sync::atomic::Ordering; 🔒

use std::sync::Arc; 🔒

use std::sync::Mutex; 🔒

use std::sync::Once; 🔒

use std::fmt; 🔒

use std::io; 🔒

use std::mem; 🔒

use std::ptr; 🔒

use std::thread; 🔒

use crossbeam_deque::Injector; 🔒

use crossbeam_deque::Steal; 🔒

use crossbeam_deque::Stealer; 🔒

use crossbeam_deque::Worker; 🔒

use smallvec::SmallVec; 🔒

use crate::job::JobFifo; 🔒

use crate::job::JobRef; 🔒

use crate::job::StackJob; 🔒

use crate::latch::AsCoreLatch; 🔒

use crate::latch::CoreLatch; 🔒

use crate::latch::Latch; 🔒

use crate::latch::LatchRef; 🔒

use crate::latch::LockLatch; 🔒

use crate::latch::OnceLatch; 🔒

use crate::latch::SpinLatch; 🔒

use crate::sleep::Sleep; 🔒

use crate::tlv::Tlv; 🔒

use crate::AcquireThreadHandler; 🔒

use crate::DeadlockHandler; 🔒

use crate::ErrorKind; 🔒

use crate::ExitHandler; 🔒

use crate::PanicHandler; 🔒

use crate::ReleaseThreadHandler; 🔒

use crate::StartHandler; 🔒

use crate::ThreadPoolBuildError; 🔒

use crate::ThreadPoolBuilder; 🔒

use crate::Yield; 🔒

use crate::unwind; 🔒

Structs

CustomSpawn

Spawns a thread with a user’s custom callback.

DefaultSpawn

Spawns a thread in the “normal” way with std::thread::Builder.

Registry

RegistryId 🔒

Terminator 🔒

ThreadBuilder

Thread builder used for customization via ThreadPoolBuilder::spawn_handler.

ThreadInfo 🔒

WorkerThread 🔒

XorShift64Star 🔒

xorshift* is a fast pseudorandom number generator which will even tolerate weak seeding, as long as it’s not zero.

Constants

WORKER_THREAD_STATE 🔒

Statics

THE_REGISTRY 🔒

THE_REGISTRY_SET 🔒

Traits

ThreadSpawn

Generalized trait for spawning a thread in the Registry.

Functions

default_global_registry 🔒

global_registry 🔒

Starts the worker threads (if that has not already happened). If initialization has not already occurred, use the default configuration.

in_worker 🔒

If already in a worker-thread, just execute op. Otherwise, execute op in the default thread-pool. Either way, block until op completes and return its return value. If op panics, that panic will be propagated as well. The second argument indicates true if injection was performed, false if executed directly.

init_global_registry 🔒

Starts the worker threads (if that has not already happened) with the given builder.

main_loop 🔒 ^⚠

mark_blocked_and_wait

Mark a Rayon worker thread as blocked. This triggers the deadlock handler if no other worker thread is active. Then wait for the user-specified condition.

mark_unblocked

Mark a previously blocked Rayon worker thread as unblocked

set_global_registry 🔒

Starts the worker threads (if that has not already happened) by creating a registry with the given callback.