anode 0.1.0

Concurrency library for Rust.
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

use test_utils::SHORT_WAIT;
use crate::multilock::{Fairness, MultiLock};
use crate::test_utils;

#[test]
fn timeout_in_write_unblocks_readers() {
    let lock = MultiLock::new(0, Fairness::WriteBiased);
    let guard_1 = lock.read();
    let guard_2 = lock.read();

    // cannot acquire a write lock with active readers
    let guard_3 = lock.try_write(SHORT_WAIT);
    assert!(guard_3.is_none());

    // the timeout should have cleared the writer_pending flag
    let guard_4 = lock.read();
    drop(guard_1);
    drop(guard_2);
    drop(guard_4);
}


#[test]
fn timeout_in_upgrade_unblocks_readers() {
    let lock = MultiLock::new(0, Fairness::WriteBiased);
    let guard_1 = lock.read();
    let guard_2 = lock.read();

    // cannot acquire upgrade a read lock with active readers
    let guard_3 = lock.read().try_upgrade(SHORT_WAIT);
    assert!(guard_3.is_unchanged());

    // the timeout should have cleared the writer_pending flag
    let guard_4 = lock.read();
    drop(guard_1);
    drop(guard_2);
    drop(guard_4);
}

// #[test]
// fn await_timeout_in_pending_writer() {
//     let lock = Arc::new(MultiLock::new(0, Fairness::WriteBiased));
//     let guard_1 = lock.read();
//
// }