process-events-streaming

Rust库，用于基于事件的多进程执行（阻塞和非阻塞模式），并行且具有数据流功能

根据提供的进程请求运行进程。根据进程的生命周期、进程信息和与该事件关联的数据 ProcessEvent 生成各种事件，并生成与该事件相关联的进程数据 ProcessData

参数

ProcessRequest : ProcessRequest // 启动进程的请求结构

返回

对于阻塞模式，它返回 None，对于非阻塞模式，它将返回 [Some(io::Result<JoinHandle<()>>)]，以便调用者可以在需要时加入并等待进程完成！

示例

// Setup callback (for the process events and data streaming)
//
use process_events_streaming::{ProcessRequest, ProcessResult, ProcessData, ProcessEvent};
use std::{thread, time::Duration};
     let callback = |status: &ProcessEvent, data: &ProcessData| -> ProcessResult {
         match status {
             ProcessEvent::Started => {
                 println!(
                     "Event {:?} | req-id {}  | Pids: {:?}",
                     status,
                     data.request.as_ref().unwrap().request_id,
                     data.child_pids()
                 );
             }
             ProcessEvent::IOData => {
                 println!(
                     "Event {:?} | req-id {} | # {} : {}",
                     status,
                     data.request.as_ref().unwrap().request_id,
                     data.line_number,
                     data.line
                 );
                 //now assume we want to exit the process with some data
                 let mut result = ProcessResult::new();
                 result.set_exit_flag_and_success(true, Ok(true));
                 result.data_num = Some(8111981);
                 result.data_vec_str = Some(vec![String::from("I found my hidden data!")]);
                 return result;

                 //demo how to kill/stop
                 //_ = data.kill();
             }
             other => {
                 if !data.line.is_empty() {
                     println!(
                         "Event {:?} | req-id {} | additional detail(s): {}",
                         other,
                         data.request.as_ref().unwrap().request_id,
                         data.line
                     );
                 } else {
                     println!(
                         "Event {:?} | req-id {}",
                         other,
                         data.request.as_ref().unwrap().request_id
                     );
                 }
             }
         }
         ProcessResult::new()
     };



   let request2 = ProcessRequest {
       request_id: 151,
       callback: Some(Arc::new(callback)),
       use_shell: true,
       cmd_line: vec![vec![
           String::from("echo"),
           String::from("stdout"),
           String::from("&"),
           String::from("echo"),
           String::from("stderr"),
           String::from(">&2"),
       ]],
       non_blocking_mode: true,
   };

   // non Blocking mode
   let process_result = ProcessRequest::start(request2);
   println!("Returned from Start! of non blocking");

   let mut internal_data = ProcessResult::new();
   //check & wait for the non blocking mode
   if process_result.join_handle.is_some() {
       if process_result.join_handle.as_ref().unwrap().is_ok() {
           internal_data = process_result.join_handle.unwrap().unwrap().join().unwrap();
           println!(
               "Start - join waiting over in non blocking mode {:?}",
               internal_data
           );
       } else {
           internal_data.success = Err(process_result.join_handle.unwrap().err().unwrap());
           println!(
               "Start - Error in non blocking mode {:?}",
               internal_data.success
           );
       }
   } else {
       internal_data = process_result;
   }
   println!("result dump : {:?}", internal_data);

   println!(
    "test_using_sh_output_streaming, start calc in windows {:?}",
    ProcessRequest::start(ProcessRequest {
        request_id: 191,
        callback: Some(Arc::new(callback)),
        use_shell: true,
        cmd_line: vec![vec![String::from("calc")]],
        non_blocking_mode: false,
    }));

文件 [../src/lib.rs] 包含了在 #[test] 下的详细示例

测试中进程事件的样本输出

running 2 tests
Event Starting | req-id 151 | additional detail(s): Executing in thread-context -> id: ThreadId(2), name: Some("tests::test_using_sh_output_streaming_new_version")
Event Started | req-id 151  | Pids: [14120]
Event IOData | req-id 151 | # 1 : stdout 

Event ExitRequested | req-id 151 | additional detail(s): stdout

Event Exited | req-id 151
Returned from Start! of non blocking
result dump : ProcessResult { join_handle: None, should_exit: Some(true), success: Ok(true), data_vec_str: Some(["I found my hidden data!"]), data_bool: None, data_num: Some(8111981), data_decimal: None }

Event Starting | req-id 105 | additional detail(s): Executing in thread-context -> id: ThreadId(3), name: Some("pes_th_rq_105")
Event Started | req-id 105  | Pids: [10332, 864]
Event IOData | req-id 105 | # 1 : 
Event IOData | req-id 105 | # 2 :
Event IOData | req-id 105 | # 3 :                5 Dir(s)  679,760,900,096 bytes free
Event IOData | req-id 105 | # 4 :                7 File(s)          8,018 bytes
Event IOData | req-id 105 | # 5 :  Directory of C:\process-events-streaming
Event IOData | req-id 105 | # 6 : 04-11-2022  01:53 PM               210 rustfmt.toml
Event IOData | req-id 105 | # 7 : 04-11-2022  04:58 PM               682 Cargo.toml
Event IOData | req-id 105 | # 8 : 04-11-2022  05:09 PM    <DIR>          .github
Event IOData | req-id 105 | # 9 : 04-11-2022  05:09 PM    <DIR>          src
Event IOData | req-id 105 | # 10 : 04-11-2022  09:58 PM                91 .gitconfig
Event IOData | req-id 105 | # 11 : 04-11-2022  09:59 PM             1,091 LICENSE
Event IOData | req-id 105 | # 12 : 04-11-2022  10:11 PM               344 .gitignore
Event IOData | req-id 105 | # 13 : 04-11-2022  10:45 PM             3,600 README.md
Event IOEof | req-id 105
Event Exited | req-id 105
test_using_sh_output_streaming, demo pipe-line ()

Event Starting | req-id 106 | additional detail(s): Executing in thread-context -> id: ThreadId(3), name: Some("pes_th_rq_106")
Event Started | req-id 106  | Pids: [25936]
Event IOData | req-id 106 | # 1 : \"Sandy\" 
Event IOEof | req-id 106
Event Exited | req-id 106
test_using_sh_output_streaming, demo double quotes ()

Event StartError | req-id 107 | additional detail(s): "Command line - arguments are unavailable!"
test_using_sh_output_streaming, no arguments means start error ()

许可证

许可协议下

• MIT许可证 (LICENSE-MIT 或 https://opensource.org/licenses/MIT)

依赖关系

此库使用一个出色的库 'duct' 来处理底层进程