txmap 1.0.0

A concurrent transactional hash map with fine-grained locking and internal mutability
Documentation 
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

use crate::{
    custodian::Custodian, finisher::Finisher, finishers::finisher_trait::FinisherTrait,
    guard::Guard, ops::op_trait::OpTrait, result::TxResult,
};
use std::hash::Hash;

pub struct Transaction<'txmap, K, V, F>
where
    F: FinisherTrait<K, V>,
{
    pub(crate) base: TransactionBase<'txmap, K, V, (), F>,
}

impl<'txmap, K, V, F> Transaction<'txmap, K, V, F>
where
    K: Hash + Eq,
    F: FinisherTrait<K, V>,
{
    #[must_use]
    pub fn execute(&self) -> TxResult<F::Output> {
        self.base.execute_with_params(&())
    }
}

pub struct ParameterizedTransaction<'txmap, K, V, P, F>
where
    F: FinisherTrait<K, V>,
{
    pub(crate) base: TransactionBase<'txmap, K, V, P, F>,
}

impl<'txmap, K, V, P, F> ParameterizedTransaction<'txmap, K, V, P, F>
where
    K: Hash + Eq,
    F: FinisherTrait<K, V>,
{
    #[must_use]
    pub fn execute(&self, params: &P) -> TxResult<F::Output> {
        self.base.execute_with_params(params)
    }
}

pub(crate) struct TransactionBase<'txmap, K, V, P, F>
where
    F: FinisherTrait<K, V>,
{
    pub(crate) custodian: &'txmap Custodian<K, V>,
    pub(crate) guards_bitmask: u128,
    pub(crate) guards: Vec<Guard<K, V, P>>,
    pub(crate) ops: Vec<Box<dyn OpTrait<K, V, P>>>,
    pub(crate) finisher: Finisher<K, V, F>,
}

impl<'txmap, K, V, P, F> TransactionBase<'txmap, K, V, P, F>
where
    K: Hash + Eq,
    F: FinisherTrait<K, V>,
{
    pub fn execute_with_params(&self, params: &P) -> TxResult<F::Output> {
        let mut mutex_guards = self.custodian.guards(self.guards_bitmask);
        for (i, guard) in self.guards.iter().enumerate() {
            if !guard.is_condition_met(&mutex_guards, params) {
                return TxResult::RequirementNotMet(i, guard.name.clone());
            }
        }
        for op in &self.ops {
            op.apply(&mut mutex_guards, params);
        }
        let result = self.finisher.finish(&mutex_guards);
        TxResult::Completed(result)
    }
}