blob: 5ec6c5ccfa836c99d37c84799a7ba21ae92811bb (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
|
use std::thread;
use std::time::Duration;
use indicatif::{MultiProgress, ProgressBar, ProgressStyle};
use rand::Rng;
fn main() {
let m = MultiProgress::new();
let sty = ProgressStyle::with_template(
"[{elapsed_precise}] {bar:40.cyan/blue} {pos:>7}/{len:7} {msg}",
)
.unwrap()
.progress_chars("##-");
let n = 200;
let pb = m.add(ProgressBar::new(n));
pb.set_style(sty.clone());
pb.set_message("todo");
let pb2 = m.add(ProgressBar::new(n));
pb2.set_style(sty.clone());
pb2.set_message("finished");
let pb3 = m.insert_after(&pb2, ProgressBar::new(1024));
pb3.set_style(sty);
m.println("starting!").unwrap();
let mut threads = vec![];
let m_clone = m.clone();
let h3 = thread::spawn(move || {
for i in 0..1024 {
thread::sleep(Duration::from_millis(2));
pb3.set_message(format!("item #{}", i + 1));
pb3.inc(1);
}
m_clone.println("pb3 is done!").unwrap();
pb3.finish_with_message("done");
});
for i in 0..n {
thread::sleep(Duration::from_millis(15));
if i == n / 3 {
thread::sleep(Duration::from_secs(2));
}
pb.inc(1);
let m = m.clone();
let pb2 = pb2.clone();
threads.push(thread::spawn(move || {
let spinner = m.add(ProgressBar::new_spinner().with_message(i.to_string()));
spinner.enable_steady_tick(Duration::from_millis(100));
thread::sleep(
rand::thread_rng().gen_range(Duration::from_secs(1)..Duration::from_secs(5)),
);
pb2.inc(1);
}));
}
pb.finish_with_message("all jobs started");
for thread in threads {
let _ = thread.join();
}
let _ = h3.join();
pb2.finish_with_message("all jobs done");
m.clear().unwrap();
}
|
