Run commands in parallel, like a simple rust verision of GNU Parallel.
Just starting - more options to come :)
Usage: ``` Run commands from stdin in parallel
Usage: rust-parallel [OPTIONS]
Options:
-j, --jobs
Little demo:
``` $ cargo build -v
$ cat test echo hi echo there echo how echo are echo you
$ cat test | ./target/debug/rust-parallel -j5 are hi there how you ```
With debug logs enabled:
$ cat test | RUST_LOG=debug ./target/debug/rust-parallel
2022-11-26T15:47:41.898980Z DEBUG rust_parallel: begin main
2022-11-26T15:47:41.899717Z DEBUG rust_parallel: command_line_args = CommandLineArgs { jobs: 4 }
2022-11-26T15:47:41.899933Z DEBUG rust_parallel: read line echo hi
2022-11-26T15:47:41.900001Z DEBUG rust_parallel: read line echo there
2022-11-26T15:47:41.900049Z DEBUG rust_parallel: read line echo how
2022-11-26T15:47:41.900140Z DEBUG rust_parallel: read line echo are
2022-11-26T15:47:41.900227Z DEBUG rust_parallel: read line echo you
2022-11-26T15:47:41.900391Z DEBUG rust_parallel: after spawn_commands join_set.len() = 5
2022-11-26T15:47:41.906264Z DEBUG rust_parallel: got command status = exit status: 0
hi
2022-11-26T15:47:41.906433Z DEBUG rust_parallel: got command status = exit status: 0
how
2022-11-26T15:47:41.906371Z DEBUG rust_parallel: join_next result = Ok(CommandInfo { _line_number: 1, command: "echo hi" })
2022-11-26T15:47:41.906479Z DEBUG rust_parallel: got command status = exit status: 0
there
2022-11-26T15:47:41.906519Z DEBUG rust_parallel: join_next result = Ok(CommandInfo { _line_number: 3, command: "echo how" })
2022-11-26T15:47:41.906556Z DEBUG rust_parallel: join_next result = Ok(CommandInfo { _line_number: 2, command: "echo there" })
2022-11-26T15:47:41.906570Z DEBUG rust_parallel: got command status = exit status: 0
are
2022-11-26T15:47:41.906638Z DEBUG rust_parallel: join_next result = Ok(CommandInfo { _line_number: 4, command: "echo are" })
2022-11-26T15:47:41.911268Z DEBUG rust_parallel: got command status = exit status: 0
you
2022-11-26T15:47:41.911376Z DEBUG rust_parallel: join_next result = Ok(CommandInfo { _line_number: 5, command: "echo you" })
2022-11-26T15:47:41.911408Z DEBUG rust_parallel: end main