Expand description
On many-processor systems with multiple memory regions, there is an extra cost associated with accessing data in physical memory modules that are in a different memory region than the current processor:
- Cross-memory-region loads have higher latency (e.g. 100 ns local versus 200 ns remote).
- Cross-memory-region loads have lower throughput (e.g. 200 GBps local versus 100 GBps remote).
This crate enables you to create values that maintain separate storage per memory region.
Region-local storage may be useful in circumstances where state needs to be shared but it is fine to do so only within each memory region (e.g. because you intentionally want to avoid the overhead of cross-memory-region transfers and want to isolate the data sets).
graph TD
subgraph Region2[Memory region 2]
Processor3[Processor 3]
Processor4[Processor 4]
Processor3 --> Region2Value[Regional value]
Processor4 --> Region2Value
end
subgraph Region1[Memory region 1]
Processor1[Processor 1]
Processor2[Processor 2]
Processor1 --> Region1Value[Regional value]
Processor2 --> Region1Value
end
Think of this as an equivalent of thread_local_rc!, except operating on the memory
region boundary instead of the thread boundary.
This is part of the Folo project that provides mechanisms for high-performance hardware-aware programming in Rust.
§Applicability
A positive performance impact may be seen if all of the following conditions are true:
- The system has multiple memory regions.
- A shared data set is accessed from processors in different memory regions.
- The data set is large enough to make it unlikely to be resident in local processor caches.
- There is sufficient memory capacity to clone the data set into every memory region.
- Callers in different memory regions do not need to see each other’s writes.
As with all performance and efficiency questions, you should use a profiler to measure real impact.
§Usage
There are two ways to create region-local values:
- Define a static variable in a
region_local!block. - Use the
RegionLocaltype inside alinked::InstancePerThread<T>orlinked::InstancePerThreadSync<T>wrapper.
The difference is only a question of convenience - static variables are easier to use but come with language-driven limitations, such as needing to know in advance how many you need and defining them in the code.
In contrast, linked::InstancePerThread<RegionLocal<T>> is more flexible and you can create
any number of instances at runtime, at a cost of having to manually deliver instances to
the right place in the code.
§Usage via static variables
This crate provides the region_local! macro that enhances static variables with
region-local storage and provides interior mutability via weakly consistent
writes within the same memory region.
// RegionLocalExt provides required extension methods on region-local
// static variables, such as `with_local()` and `set_local()`.
use region_local::{region_local, RegionLocalExt};
region_local!(static FAVORITE_COLOR: String = "blue".to_string());
FAVORITE_COLOR.with_local(|color| {
println!("My favorite color is {color}");
});
FAVORITE_COLOR.set_local("red".to_string());§Usage via InstancePerThreadSync<RegionLocal<T>>
There exist situations where a static variable is not suitable. For example, the number of different region-local objects may be determined at runtime (e.g. a separate value for each log source loaded from configuration).
In this case, you can directly use the RegionLocal type which underpins the mechanisms
exposed by the macro. This type is implemented using the linked object pattern and
can be manually used via the InstancePerThread<T> or
InstancePerThreadSync<T> wrapper type, as InstancePerThreadSync<RegionLocal<T>>.
use linked::InstancePerThreadSync;
use region_local::RegionLocal;
let favorite_color_regional =
InstancePerThreadSync::new(RegionLocal::new(|| "blue".to_string()));
// This localizes the object to the current thread. Reuse this value when possible.
let favorite_color = favorite_color_regional.acquire();
favorite_color.with_local(|color| {
println!("My favorite color is {color}");
});
favorite_color.set_local("red".to_string());See the documentation of the linked crate for more details on the mechanisms
offered by the linked object pattern. Additional capabilities exist beyond those described here.
§Consistency guarantees
Writes are weakly consistent within the same memory region, with an undefined order of resolving from different threads. Writes from the same thread become visible sequentially on all threads in the same memory region.
Writes are immediately visible from the originating thread, with the caveats that:
- Writes from other threads may be applied at any time, such as between a write and an immediately following read.
- A thread, if not pinned, may migrate to a new memory region between the write and read operations, which invalidates any link between the two operations and will read from the storage of the new memory region.
In general, you can only have firm expectations about the sequencing of data produced by read operations if the writes are always performed from a single thread per memory region and the thread is pinned to processors of only a single memory region.
§Operating system compatibility
This crate relies on the collaboration between the Rust global allocator and the operating system to map virtual memory pages to the correct memory region. The default configuration in operating systems tends to encourage region-local mapping but this is not guaranteed.
Some evidence suggests that on Windows, region-local mapping is only enabled when the threads are pinned to specific processors in specific memory regions. A similar requirement is not known for Linux (at least Ubuntu 24) but this may differ based on the specific OS and configuration. Perform your own measurements to identify the behavior of your system and adjust the application structure accordingly.
Example of using this crate with processor-pinned threads (examples/region_local_1gb.rs):
region_local! {
// We allocate a 1 GB object in every memory region.
// With 4 memory regions, you should see a total of 4 GB allocated.
static DATA: Vec<u8> = vec![50; 1024 * 1024 * 1024];
}
fn main() {
let processor_set = SystemHardware::current().processors();
processor_set
.spawn_threads(|_| DATA.with_local(|data| _ = black_box(data.len())))
.into_iter()
.for_each(|x| x.join().unwrap());
println!(
"All {} threads have accessed the region-local data. Terminating in 60 seconds.",
processor_set.len()
);
thread::sleep(Duration::from_secs(60));
}§Cross-region visibility
The region_cached crate provides a similar mechanism that also publishes the value to all
memory regions instead of keeping it region-local. This may be a useful alternative if you do
not need to have separate variables per memory region but still want the efficiency benefits
of reading from local memory.
Macros§
- region_
local - Marks static variables as region-local.
Structs§
- Region
Local - Provides access to an instance of
Twhose values are local to the current memory region. Callers from different memory regions will observe different instances ofT.
Traits§
- Region
Local Copy Ext - Extension trait that adds convenience methods to region-local static variables
in a
region_local!block, specifically forCopytypes. - Region
Local Ext - Extension trait that adds convenience methods to region-local static variables
in a
region_local!block.