1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259
//! This module provides multi-threaded blink allocator\
//! with sync resets.
use core::{alloc::Layout, ptr::NonNull};
use allocator_api2::{AllocError, Allocator};
#[cfg(feature = "alloc")]
use allocator_api2::Global;
use crate::{
api::BlinkAllocator,
arena::{Arena, ArenaLocal},
};
with_global_default! {
/// Single-threaded blink allocator.
///
/// Blink-allocator is arena-based allocator that
/// allocates memory in growing chunks and serve allocations from them.
/// When chunk is exhausted a new larger chunk is allocated.
///
/// Deallocation is no-op. [`BlinkAlloc`] can be reset
/// to free all chunks except the last one, that will be reused.
///
/// Blink allocator aims to allocate a chunk large enough to
/// serve all allocations between resets.
///
/// A shared and mutable reference to the [`BlinkAlloc`] implement
/// [`Allocator`] trait.
/// When "nightly" feature is enabled, [`Allocator`] trait is
/// [`core::alloc::Allocator`]. Otherwise it is duplicated trait defined
/// in [`allocator-api2`](allocator_api2).
///
/// Resetting blink allocator requires mutable borrow, so it is not possible
/// to do while shared borrow is alive. That matches requirement of
/// [`Allocator`] trait - while [`Allocator`] instance
/// (a shared reference to [`BlinkAlloc`]) or any of its clones are alive,
/// allocated memory must be valid.
///
/// This version of blink-allocator is single-threaded. It is possible
/// to send to another thread, but cannot be shared.
/// Internally it uses [`Cell`](core::cell::Cell) for interior mutability and requires
/// that state cannot be changed from another thread.
///
#[cfg_attr(feature = "sync", doc = "For multi-threaded version see [`SyncBlinkAlloc`](crate::sync::SyncBlinkAlloc).")]
#[cfg_attr(not(feature = "sync"), doc = "For multi-threaded version see `SyncBlinkAlloc`.")]
/// Requires `"sync"` feature.
///
/// # Example
///
/// ```
/// # #![cfg_attr(feature = "nightly", feature(allocator_api))]
/// # #[cfg(not(feature = "alloc"))] fn main() {}
/// # #[cfg(feature = "alloc")] fn main() {
/// # use blink_alloc::BlinkAlloc;
/// # use allocator_api2::Allocator;
/// # use std::ptr::NonNull;
///
/// let mut blink = BlinkAlloc::new();
/// let layout = std::alloc::Layout::new::<[u32; 8]>();
/// let ptr = blink.allocate(layout).unwrap();
/// let ptr = NonNull::new(ptr.as_ptr() as *mut u8).unwrap(); // Method for this is unstable.
///
/// unsafe {
/// std::ptr::write(ptr.as_ptr().cast(), [1, 2, 3, 4, 5, 6, 7, 8]);
/// blink.deallocate(ptr, layout);
/// }
///
/// blink.reset();
/// # }
/// ```
///
/// # Example that uses nightly's `allocator_api`
///
/// ```
/// # #![cfg_attr(feature = "nightly", feature(allocator_api))]
/// # use blink_alloc::BlinkAlloc;
/// # use std::vec::Vec;
/// # #[cfg(feature = "nightly")]
/// # fn main() {
/// let mut blink = BlinkAlloc::new();
/// let mut vec = Vec::new_in(&blink);
/// vec.push(1);
/// vec.extend(1..3);
/// vec.extend(3..10);
/// drop(vec);
/// blink.reset();
/// # }
/// # #[cfg(not(feature = "nightly"))]
/// # fn main() {}
/// ```
pub struct BlinkAlloc<A: Allocator = +Global> {
arena: ArenaLocal,
allocator: A,
}
}
impl<A> Drop for BlinkAlloc<A>
where
A: Allocator,
{
fn drop(&mut self) {
// Safety:
// Same instance is used for all allocations and resets.
unsafe {
self.arena.reset(false, &self.allocator);
}
}
}
impl<A> Default for BlinkAlloc<A>
where
A: Allocator + Default,
{
#[inline]
fn default() -> Self {
Self::new_in(Default::default())
}
}
#[cfg(feature = "alloc")]
impl BlinkAlloc<Global> {
/// Creates new blink allocator that uses global allocator
/// to allocate memory chunks.
///
/// See [`BlinkAlloc::new_in`] for using custom allocator.
#[inline]
pub const fn new() -> Self {
BlinkAlloc::new_in(Global)
}
/// Creates new blink allocator that uses global allocator
/// to allocate memory chunks.
/// With this method you can specify initial chunk size.
///
/// See [`BlinkAlloc::new_in`] for using custom allocator.
#[inline]
pub const fn with_chunk_size(chunk_size: usize) -> Self {
BlinkAlloc::with_chunk_size_in(chunk_size, Global)
}
}
impl<A> BlinkAlloc<A>
where
A: Allocator,
{
/// Creates new blink allocator that uses provided allocator
/// to allocate memory chunks.
///
/// See [`BlinkAlloc::new`] for using global allocator.
#[inline]
pub const fn new_in(allocator: A) -> Self {
BlinkAlloc::with_chunk_size_in(0, allocator)
}
/// Creates new blink allocator that uses global allocator
/// to allocate memory chunks.
/// With this method you can specify initial chunk size.
///
/// See [`BlinkAlloc::new_in`] for using custom allocator.
#[inline]
pub const fn with_chunk_size_in(chunk_size: usize, allocator: A) -> Self {
BlinkAlloc {
arena: ArenaLocal::new(chunk_size),
allocator,
}
}
/// Allocates memory with specified layout from this allocator.
/// If needed it will allocate new chunk using underlying allocator.
/// If chunk allocation fails, it will return `Err`.
#[inline]
pub fn allocate(&self, layout: Layout) -> Result<NonNull<[u8]>, AllocError> {
// Safety:
// Same instance is used for all allocations and resets.
unsafe { self.arena.alloc(layout, &self.allocator) }
}
/// Resizes memory allocation.
/// Potentially happens in-place.
#[inline]
unsafe fn resize(
&self,
ptr: NonNull<u8>,
old_size: usize,
new_layout: Layout,
) -> Result<NonNull<[u8]>, AllocError> {
// Safety:
// Same instance is used for all allocations and resets.
unsafe {
self.arena
.resize(ptr, old_size, new_layout, &self.allocator)
}
}
/// Resets this allocator, deallocating all chunks except the last one.
/// Last chunk will be reused.
/// With steady memory usage after few iterations
/// chunk size should be sufficient for all allocations between resets.
#[inline]
pub fn reset(&mut self) {
// Safety:
// Same instance is used for all allocations and resets.
unsafe {
self.arena.reset(true, &self.allocator);
}
}
}
unsafe impl<A> Allocator for BlinkAlloc<A>
where
A: Allocator,
{
#[inline]
fn allocate(&self, layout: Layout) -> Result<NonNull<[u8]>, AllocError> {
BlinkAlloc::allocate(self, layout)
}
#[inline]
unsafe fn grow(
&self,
ptr: NonNull<u8>,
old_layout: Layout,
new_layout: Layout,
) -> Result<NonNull<[u8]>, AllocError> {
BlinkAlloc::resize(self, ptr, old_layout.size(), new_layout)
}
#[inline]
unsafe fn deallocate(&self, ptr: NonNull<u8>, layout: Layout) {
let _ = (ptr, layout);
}
}
unsafe impl<A> Allocator for &mut BlinkAlloc<A>
where
A: Allocator,
{
#[inline]
fn allocate(&self, layout: Layout) -> Result<NonNull<[u8]>, AllocError> {
BlinkAlloc::allocate(&**self, layout)
}
#[inline]
unsafe fn deallocate(&self, ptr: NonNull<u8>, layout: Layout) {
let _ = (ptr, layout);
}
}
unsafe impl<A> BlinkAllocator for BlinkAlloc<A>
where
A: Allocator,
{
#[inline]
fn reset(&mut self) {
BlinkAlloc::reset(self)
}
}