mirror of
https://github.com/Drop-OSS/drop-app.git
synced 2026-07-24 08:53:18 +10:00
e91f79bf57
Signed-off-by: quexeky <git@quexeky.dev>
50 lines
1.2 KiB
Rust
50 lines
1.2 KiB
Rust
use std::sync::{
|
|
atomic::{AtomicBool, Ordering},
|
|
Arc,
|
|
};
|
|
|
|
#[derive(PartialEq, Eq, PartialOrd, Ord)]
|
|
pub enum DownloadThreadControlFlag {
|
|
Stop,
|
|
Go,
|
|
}
|
|
/// Go => true
|
|
/// Stop => false
|
|
impl From<DownloadThreadControlFlag> for bool {
|
|
fn from(value: DownloadThreadControlFlag) -> Self {
|
|
match value {
|
|
DownloadThreadControlFlag::Go => true,
|
|
DownloadThreadControlFlag::Stop => false,
|
|
}
|
|
}
|
|
}
|
|
/// true => Go
|
|
/// false => Stop
|
|
impl From<bool> for DownloadThreadControlFlag {
|
|
fn from(value: bool) -> Self {
|
|
match value {
|
|
true => DownloadThreadControlFlag::Go,
|
|
false => DownloadThreadControlFlag::Stop,
|
|
}
|
|
}
|
|
}
|
|
|
|
#[derive(Clone)]
|
|
pub struct DownloadThreadControl {
|
|
inner: Arc<AtomicBool>,
|
|
}
|
|
|
|
impl DownloadThreadControl {
|
|
pub fn new(flag: DownloadThreadControlFlag) -> Self {
|
|
Self {
|
|
inner: Arc::new(AtomicBool::new(flag.into())),
|
|
}
|
|
}
|
|
pub fn get(&self) -> DownloadThreadControlFlag {
|
|
self.inner.load(Ordering::Relaxed).into()
|
|
}
|
|
pub fn set(&self, flag: DownloadThreadControlFlag) {
|
|
self.inner.store(flag.into(), Ordering::Relaxed);
|
|
}
|
|
}
|