abpl 0.1.0

A collection of Rust boilerplate: a reloadable-systemd-service lifecycle helper, a hot-reloading axum wrapper, a serializable/typed error derive macro, and small utility newtypes.
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

use std::{
	sync::mpsc::{Receiver, RecvTimeoutError, SyncSender, TrySendError, sync_channel},
	thread::{sleep, yield_now},
	time::{Duration, Instant},
};

#[derive(Debug)]
pub struct Sleeper {
	rx: Receiver<()>,
}
impl Sleeper {
	/// Sleeps the current thread until the deadline, or until `SleeperHandle.cancel` was called on another thread.
	pub fn sleep_until(&self, deadline: Instant) {
		let mut now = Instant::now();
		if deadline <= now {
			yield_now();
			return;
		}
		// fixme: use recv_deadline and sleep_until after those have been stabilized
		if self.rx.recv_timeout(deadline.duration_since(now)) == Err(RecvTimeoutError::Disconnected) {
			// If no handlers exist, we might have some more sleeping to do
			now = Instant::now();
			if deadline > now {
				sleep(deadline.duration_since(now));
			}
		}
	}

	/// Sleeps the current thread for the specified duration, or until `SleeperHandle.cancel` was called on another thread.
	pub fn sleep(&self, dur: Duration) {
		let now = Instant::now();
		let Some(deadline) = now.checked_add(dur) else {
			sleep(dur);
			return;
		};
		self.sleep_until(deadline);
	}
}

#[derive(Debug, Clone)]
pub struct SleeperHandle {
	tx: SyncSender<()>,
}
impl SleeperHandle {
	/// Cancels the tread is sleeping via `Sleeper`. If no thread currently is using the `Sleeper`, then this is a
	/// noop. Returns `false` if the corresponding `Sleeper` is gone.
	pub fn cancel(&self) -> bool {
		self.tx.try_send(()) != Err(TrySendError::Disconnected(()))
	}
}

pub fn cancelable_sleep() -> (SleeperHandle, Sleeper) {
	let (tx, rx) = sync_channel(0);
	(SleeperHandle { tx }, Sleeper { rx })
}

#[cfg(test)]
#[path = "../tests/thread/cancelable.rs"]
mod tests;