Go to file
John Nunley 8f11a87281
v5.2.0
Signed-off-by: John Nunley <dev@notgull.net>
2024-02-28 21:15:47 -08:00
.github ci: Use cargo-hack's --rust-version flag for msrv check 2024-01-07 02:52:24 +09:00
benches chore: Polish the implementation of the new API 2024-02-03 09:49:22 -08:00
examples ex: Remove unsafe code from mutex example 2024-02-03 09:49:22 -08:00
src feat: Mark StackSlot as Sync 2024-02-25 18:02:44 -08:00
tests feat: Move EventListener back onto the heap 2024-02-03 09:49:22 -08:00
.gitignore Remove Cargo.lock 2020-05-16 19:46:27 +02:00
CHANGELOG.md v5.2.0 2024-02-28 21:15:47 -08:00
Cargo.toml v5.2.0 2024-02-28 21:15:47 -08:00
LICENSE-APACHE Initial commit 2020-05-16 19:44:50 +02:00
LICENSE-MIT Initial commit 2020-05-16 19:44:50 +02:00
README.md Fix build badge and update links (#45) 2022-12-18 07:05:53 -08:00

README.md

event-listener

Build License Cargo Documentation

Notify async tasks or threads.

This is a synchronization primitive similar to eventcounts invented by Dmitry Vyukov.

You can use this crate to turn non-blocking data structures into async or blocking data structures. See a simple mutex implementation that exposes an async and a blocking interface for acquiring locks.

Examples

Wait until another thread sets a boolean flag:

use std::sync::atomic::{AtomicBool, Ordering};
use std::sync::Arc;
use std::thread;
use std::time::Duration;
use event_listener::Event;

let flag = Arc::new(AtomicBool::new(false));
let event = Arc::new(Event::new());

// Spawn a thread that will set the flag after 1 second.
thread::spawn({
    let flag = flag.clone();
    let event = event.clone();
    move || {
        // Wait for a second.
        thread::sleep(Duration::from_secs(1));

        // Set the flag.
        flag.store(true, Ordering::SeqCst);

        // Notify all listeners that the flag has been set.
        event.notify(usize::MAX);
    }
});

// Wait until the flag is set.
loop {
    // Check the flag.
    if flag.load(Ordering::SeqCst) {
        break;
    }

    // Start listening for events.
    let listener = event.listen();

    // Check the flag again after creating the listener.
    if flag.load(Ordering::SeqCst) {
        break;
    }

    // Wait for a notification and continue the loop.
    listener.wait();
}

License

Licensed under either of

at your option.

Contribution

Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in the work by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.