fix encoder using too many threads
This commit is contained in:
parent
da1f18b427
commit
5ba44d216f
1 changed files with 2 additions and 7 deletions
|
@ -433,13 +433,8 @@ async fn main() {
|
||||||
*running.lock().unwrap() -= 1;
|
*running.lock().unwrap() -= 1;
|
||||||
println!("encode: encoded {n}");
|
println!("encode: encoded {n}");
|
||||||
});
|
});
|
||||||
#[cfg(debug_assertions)]
|
while *running.lock().unwrap() < 5 {
|
||||||
{
|
tokio::time::sleep(Duration::from_millis(100)).await;
|
||||||
thread::sleep(Duration::from_millis(5000));
|
|
||||||
}
|
|
||||||
#[cfg(not(debug_assertions))]
|
|
||||||
{
|
|
||||||
thread::sleep(Duration::from_millis(200));
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
while *running.lock().unwrap() != 0 {
|
while *running.lock().unwrap() != 0 {
|
||||||
|
|
Loading…
Reference in a new issue