Skip to main content

SyncBtreeMap

Struct SyncBtreeMap 

Source
pub struct SyncBtreeMap<K: Eq + Hash, V> { /* private fields */ }
Expand description

this sync map used to many reader,writer less.space-for-time strategy

Reads are lock-free: get/iter/dirty_ref/len/contains_key only register a reader slot with an atomic counter and then read the map without any lock (readers never block each other and never touch a lock word). Writes take a mutex, raise a writing flag and wait until all in-flight readers are gone before mutating the map in place — O(log n), no whole-container copy and no Clone requirement on K/V.

§Deadlock note

A read guard makes writers wait until it is dropped. Do not call a write method while a read/write guard is alive in the same scope: drop the guard first (e.g. drop(g) before insert/remove/get_mut), otherwise the writer waits for its own guard and deadlocks.

Implementations§

Source§

impl<K, V> SyncBtreeMap<K, V>
where K: Eq + Hash,

Source

pub fn new_arc() -> Arc<Self>

Source

pub fn new() -> Self

Source

pub fn with_capacity(_capacity: usize) -> Self

Source

pub fn with_map(map: BTreeMap<K, V>) -> Self
where K: Ord,

Source

pub fn insert(&self, k: K, v: V) -> Option<V>
where K: Ord,

Source

pub fn insert_mut(&mut self, k: K, v: V) -> Option<V>
where K: Ord,

Source

pub fn remove(&self, k: &K) -> Option<V>
where K: Ord,

Source

pub fn remove_mut(&mut self, k: &K) -> Option<V>
where K: Ord,

Source

pub fn len(&self) -> usize

Source

pub fn is_empty(&self) -> bool

Source

pub fn clear(&self)

Source

pub fn clear_mut(&mut self)

Source

pub fn shrink_to_fit(&self)

Source

pub fn shrink_to_fit_mut(&mut self)

Source

pub fn from(map: BTreeMap<K, V>) -> Self
where K: Eq + Hash + Ord,

Source

pub fn get<Q>(&self, k: &Q) -> Option<BtreeMapGet<'_, V>>
where K: Borrow<Q> + Ord, Q: Ord + ?Sized,

Returns a read-guarded reference to the value corresponding to the key.

The key may be any borrowed form of the map’s key type.

The read is lock-free: it only registers a reader slot, so concurrent reads never block each other and never take a lock. Writers wait for the returned guard to be dropped before mutating the map.

§Examples
use dark_std::sync::{SyncBtreeMap};

let mut map = SyncBtreeMap::new();
map.insert_mut(1, "a");
assert_eq!(*map.get(&1).unwrap(), "a");
assert_eq!(map.get(&2).is_none(), true);
Source

pub fn get_mut(&self, k: &K) -> Option<BtreeMapRefMut<'_, K, V>>
where K: Ord,

Returns a write-guarded mutable reference to the value of the key.

The guard holds the writer lock (writers are mutually exclusive and wait for in-flight readers) until it is dropped, so the mutable reference can never race with concurrent readers or writers. Drop it before calling another method from the same scope.

Source

pub fn contains_key<Q>(&self, k: &Q) -> bool
where K: Borrow<Q> + Ord, Q: Ord + ?Sized,

Source

pub fn iter(&self) -> BtreeMapIter<'_, K, V>

Source

pub fn iter_mut(&self) -> BtreeMapIterMut<'_, K, V>

Source

pub fn into_iter(self) -> MapIntoIter<K, V>
where K: Ord,

Source

pub fn dirty_ref(&self) -> ReadMapGuard<'_, BTreeMap<K, V>>

Source

pub fn into_inner(self) -> BTreeMap<K, V>
where K: Ord,

Trait Implementations§

Source§

impl<K: Clone + Eq + Hash + Ord, V: Clone> Clone for SyncBtreeMap<K, V>

Source§

fn clone(&self) -> Self

Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more
Source§

impl<K, V> Debug for SyncBtreeMap<K, V>
where K: Eq + Hash + Debug, V: Debug,

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more
Source§

impl<K: Eq + Hash, V> Default for SyncBtreeMap<K, V>

Source§

fn default() -> Self

Returns the “default value” for a type. Read more
Source§

impl<'de, K, V> Deserialize<'de> for SyncBtreeMap<K, V>
where K: Eq + Hash + Ord + Deserialize<'de>, V: Deserialize<'de>,

Source§

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
where D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer. Read more
Source§

impl<K, V> Display for SyncBtreeMap<K, V>
where K: Eq + Hash + Debug, V: Debug,

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more
Source§

impl<K: Eq + Hash + Ord, V> From<BTreeMap<K, V>> for SyncBtreeMap<K, V>

Source§

fn from(arg: BTreeMap<K, V>) -> Self

Converts to this type from the input type.
Source§

impl<K: Eq + Hash + Ord, V> IntoIterator for SyncBtreeMap<K, V>

Source§

type Item = (K, V)

The type of the elements being iterated over.
Source§

type IntoIter = IntoIter<K, V>

Which kind of iterator are we turning this into?
Source§

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value. Read more
Source§

impl<K: Eq + Hash, V: Send> Send for SyncBtreeMap<K, V>

Source§

impl<K, V> Serialize for SyncBtreeMap<K, V>
where K: Eq + Hash + Serialize + Ord, V: Serialize,

Source§

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
where S: Serializer,

Serialize this value into the given Serde serializer. Read more
Source§

impl<K: Eq + Hash, V: Sync> Sync for SyncBtreeMap<K, V>

Auto Trait Implementations§

§

impl<K, V> !Freeze for SyncBtreeMap<K, V>

§

impl<K, V> !RefUnwindSafe for SyncBtreeMap<K, V>

§

impl<K, V> Unpin for SyncBtreeMap<K, V>

§

impl<K, V> UnsafeUnpin for SyncBtreeMap<K, V>

§

impl<K, V> UnwindSafe for SyncBtreeMap<K, V>

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> DeserializeOwned for T
where T: for<'de> Deserialize<'de>,

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T> ToString for T
where T: Display + ?Sized,

Source§

fn to_string(&self) -> String

Converts the given value to a String. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.