Categories
Tags
3d algorithms alignment analyze APIT Arc Architecture arm ascii assembly asynchronous base64 BitHacks Blogging box c c23 clang clang-format client clippy cmake compiler Computer concat concurrency const_fn constexpr contravariant cos covariant cpp cpu crate CS Customization cybersecurity DataStructure db debugging Demo deserialization discrete doc DP drawio dtruss Dynamic emulator example Example FFI flamegraph flat_map fold format FP fsanitize Functional FunctionalProgramming functions futures Fuwari game GATs gcc gccrs generics gitignore glibc GUI hacking hashmap haskell heap hyperfine Imperative interop invariant iterator join justfile kernel LaTeX leak LFU linux lto MachineLearning macOS map Markdown math ML mmap mod nc OnceLock optimization OS ownership panic parallels perf physics pin postgresql product profiling pub radare2 rayon release reverse RPIT rust sanitizer Science science serialization server shift sin size SmallProjects socket std strace String StringView strip strlen struct sum super surrealdb SWAR swisstable synchronous tan thread time toml tracing traits triangulation uint32_t UnsafeRust utf16 utf8 Video vulkan wsl x86_64 xilem zig
253 words
1 minutes
260202_thread_local_basic001
link
thread_local
Sure. Here’s a very simple example showing the key advantage of thread_local!: each thread has its own value.
use std::cell::Cell;
use std::thread;
thread_local! {
static COUNTER: Cell<u32> = const { Cell::new(0) };
}
fn main() {
let t1 = thread::spawn(|| {
COUNTER.with(|counter| {
counter.set(counter.get() + 1);
counter.set(counter.get() + 1);
println!("Thread 1: {}", counter.get());
});
});
let t2 = thread::spawn(|| {
COUNTER.with(|counter| {
counter.set(counter.get() + 1);
println!("Thread 2: {}", counter.get());
});
});
t1.join().unwrap();
t2.join().unwrap();
// Main thread has its own COUNTER.
COUNTER.with(|counter| {
println!("Main thread: {}", counter.get());
});
}Possible output:
Thread 1: 2
Thread 2: 1
Main thread: 0What’s happening?
Even though we wrote only one:
static COUNTER: Cell<u32>there are actually three independent counters:
COUNTER
│
┌────────┼────────┐
↓ ↓ ↓
Main Thread1 Thread2
0 2 1When Thread 1 does:
counter.set(counter.get() + 1);it changes Thread 1’s counter only.
Thread 2 has a completely separate counter.
Compare with a normal global variable
Without thread-local storage, you might need:
static COUNTER: Mutex<u32> = ...;because multiple threads would be accessing the same value.
With thread_local!:
thread_local! {
static COUNTER: Cell<u32> = const { Cell::new(0) };
}you don’t need a Mutex, because each thread owns its own copy.
For your original compression example, the same idea would look like:
thread_local! {
static COMPRESSION_ENABLED: Cell<bool> =
const { Cell::new(false) };
}
fn compress() {
COMPRESSION_ENABLED.with(|enabled| {
enabled.set(true);
println!("compression: {}", enabled.get());
});
}So the mental model is simply:
thread_local!= “Give every thread its own private copy of this variable.”
260202_thread_local_basic001
https://younghakim7.github.io/blog/posts/260202_thread_local_basic001/