mirror of
https://github.com/bevyengine/bevy
synced 2024-12-27 05:23:07 +00:00
34 lines
1 KiB
Rust
34 lines
1 KiB
Rust
|
use bevy_tasks::TaskPoolBuilder;
|
||
|
|
||
|
// This sample demonstrates creating a thread pool with 4 tasks and spawning 40 tasks that spin
|
||
|
// for 100ms. It's expected to take about a second to run (assuming the machine has >= 4 logical
|
||
|
// cores)
|
||
|
|
||
|
fn main() {
|
||
|
let pool = TaskPoolBuilder::new()
|
||
|
.thread_name("Busy Behavior ThreadPool".to_string())
|
||
|
.num_threads(4)
|
||
|
.build();
|
||
|
|
||
|
let t0 = std::time::Instant::now();
|
||
|
pool.scope(|s| {
|
||
|
for i in 0..40 {
|
||
|
s.spawn(async move {
|
||
|
let now = std::time::Instant::now();
|
||
|
while std::time::Instant::now() - now < std::time::Duration::from_millis(100) {
|
||
|
// spin, simulating work being done
|
||
|
}
|
||
|
|
||
|
println!(
|
||
|
"Thread {:?} index {} finished",
|
||
|
std::thread::current().id(),
|
||
|
i
|
||
|
);
|
||
|
})
|
||
|
}
|
||
|
});
|
||
|
|
||
|
let t1 = std::time::Instant::now();
|
||
|
println!("all tasks finished in {} secs", (t1 - t0).as_secs_f32());
|
||
|
}
|