Struct Dekker

pub struct Dekker<T> { /* private fields */ }

Provides mutually exclusive access to a shared object using Dekker’s algorithm.

Implementations

impl<T> Dekker<T>

pub fn new(shared: T) -> (Process<T>, Process<T>)

Allocates a new shared object and returns two processes to access it.

Examples found in repository

examples/count.rs (line 6)

fn main() {
    // Create two process handles.
    let (mut p1, mut p2) = Dekker::new(0);

    // Create a new thread and move one handle.
    let other = thread::spawn(move || {
        // Increment by one five times.
        for _ in 0..5 {
            println!("Incrementing in secondary thread.");
            *p2.lock() += 1;
        }
    });

    // Increment by one another five times.
    for _ in 0..5 {
        println!("Incrementing in main thread.");
        *p1.lock() += 1;
    }

    // Join the threads.
    other.join().unwrap();

    println!("The counter is now at {}.", *p1.lock());
}