migrate to tokio for asynchronous processing

Cargo.toml

@@ -51,6 +51,10 @@ version = "^0"
 default-features = false
 features = ["termion"]
 
+[dependencies.tokio]
+version = "^1"
+features = [ "full" ]
+
 [dependencies.uuid]
 version = "^1"
 features = ["v4", "fast-rng", "macro-diagnostics"]

src/commands/delete_files.rs

@@ -6,7 +6,7 @@ use termion::event::Key;
 use crate::context::AppContext;
 use crate::error::{JoshutoError, JoshutoErrorKind, JoshutoResult};
 use crate::history::DirectoryHistory;
-use crate::io::{FileOperation, FileOperationOptions, IoWorkerThread};
+use crate::io::{FileOperation, FileOperationOptions, IoWorkerTask};
 use crate::ui::widgets::TuiPrompt;
 use crate::ui::AppBackend;
 
@@ -49,12 +49,12 @@ fn delete_files(
     };
 
     let dest = path::PathBuf::new();
-    let worker_thread = IoWorkerThread::new(file_op, paths.clone(), dest, options);
+    let worker_task = IoWorkerTask::new(file_op, paths.clone(), dest, options);
     if background {
-        context.worker_context_mut().push_worker(worker_thread);
+        context.worker_context_mut().push_worker(worker_task);
     } else {
         let (wtx, _) = mpsc::channel();
-        worker_thread.start(wtx)?;
+        worker_task.start(wtx)?;
     }
 
     let history = context.tab_context_mut().curr_tab_mut().history_mut();

src/commands/file_ops.rs

@@ -3,7 +3,7 @@ use std::process::{Command, Stdio};
 
 use crate::context::{AppContext, LocalStateContext};
 use crate::error::{JoshutoError, JoshutoErrorKind, JoshutoResult};
-use crate::io::{FileOperation, FileOperationOptions, IoWorkerThread};
+use crate::io::{FileOperation, FileOperationOptions, IoWorkerTask};
 
 fn new_local_state(context: &mut AppContext, file_op: FileOperation) -> Option<()> {
     let list = context.tab_context_ref().curr_tab_ref().curr_list_ref()?;
@@ -41,8 +41,8 @@ pub fn paste(context: &mut AppContext, options: FileOperationOptions) -> Joshuto
     match context.take_local_state() {
         Some(state) if !state.paths.is_empty() => {
             let dest = context.tab_context_ref().curr_tab_ref().cwd().to_path_buf();
-            let worker_thread = IoWorkerThread::new(state.file_op, state.paths, dest, options);
-            context.worker_context_mut().push_worker(worker_thread);
+            let worker_task = IoWorkerTask::new(state.file_op, state.paths, dest, options);
+            context.worker_context_mut().push_worker(worker_task);
             Ok(())
         }
         _ => Err(JoshutoError::new(