Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,89 @@ | ||
| use std::{ | ||
| sync::{Arc, Mutex}, | ||
| collections::HashMap, | ||
| }; | ||
|
|
||
| use ntex::{rt, web}; | ||
| use futures_util::Future; | ||
|
|
||
| use nanocl_error::io::{IoResult, IoError}; | ||
|
|
||
| use nanocl_stubs::system::NativeEventAction; | ||
|
|
||
| #[derive(Clone)] | ||
| pub struct ObjTask { | ||
| pub kind: NativeEventAction, | ||
| pub fut: Arc<rt::JoinHandle<IoResult<()>>>, | ||
| } | ||
|
|
||
| impl ObjTask { | ||
| pub fn new<F>(kind: NativeEventAction, task: F) -> Self | ||
| where | ||
| F: Future<Output = IoResult<()>> + 'static, | ||
| { | ||
| let fut = Arc::new(rt::spawn(task)); | ||
| Self { kind, fut } | ||
| } | ||
| } | ||
|
|
||
| #[derive(Clone, Default)] | ||
| pub struct TaskManager { | ||
| pub tasks: Arc<Mutex<HashMap<String, ObjTask>>>, | ||
| } | ||
|
|
||
| impl TaskManager { | ||
| pub fn new() -> Self { | ||
| Self::default() | ||
| } | ||
|
|
||
| pub async fn add_task(&self, key: &str, task: ObjTask) -> IoResult<()> { | ||
| let key = key.to_owned(); | ||
| let tasks = Arc::clone(&self.tasks); | ||
| web::block(move || { | ||
| let mut tasks = tasks | ||
| .lock() | ||
| .map_err(|err| IoError::interupted("Task", err.to_string().as_str()))?; | ||
| tasks.insert(key, task); | ||
| Ok::<_, IoError>(()) | ||
| }) | ||
| .await?; | ||
| Ok(()) | ||
| } | ||
|
|
||
| pub async fn remove_task(&self, key: &str) -> IoResult<()> { | ||
| let key = key.to_owned(); | ||
| let tasks = Arc::clone(&self.tasks); | ||
| web::block(move || { | ||
| let mut tasks = tasks | ||
| .lock() | ||
| .map_err(|err| IoError::interupted("Task", err.to_string().as_str()))?; | ||
| let task = tasks.get(&key); | ||
| if let Some(task) = task { | ||
| task.fut.abort(); | ||
| } | ||
| tasks.remove(&key); | ||
| Ok::<_, IoError>(()) | ||
| }) | ||
| .await?; | ||
| Ok(()) | ||
| } | ||
|
|
||
| pub async fn get_task(&self, key: &str) -> Option<ObjTask> { | ||
| let key = key.to_owned(); | ||
| let tasks = Arc::clone(&self.tasks); | ||
| let res = web::block(move || { | ||
| let tasks = tasks | ||
| .lock() | ||
| .map_err(|err| IoError::interupted("Task", err.to_string().as_str()))?; | ||
| Ok::<_, IoError>(tasks.get(&key).cloned()) | ||
| }) | ||
| .await; | ||
| match res { | ||
| Ok(res) => res, | ||
| Err(err) => { | ||
| log::error!("Failed to get task: {}", err); | ||
| None | ||
| } | ||
| } | ||
| } | ||
| } | ||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters