Skip to content

Commit

Permalink
[#166] server.thread.limit 동작 구현
Browse files Browse the repository at this point in the history
  • Loading branch information
myyrakle committed Dec 4, 2024
1 parent 767c8b6 commit 5a4c47f
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions rupring/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -445,6 +445,10 @@ impl<T: IModule + Clone + Copy + Sync + Send + 'static> RupringFactory<T> {

runtime_builder.enable_all();

if let Some(thread_limit) = self.application_properties.server.thread_limit {
runtime_builder.worker_threads(thread_limit);
}

let runtime = Builder::new_multi_thread().enable_all().build()?;

let result = runtime.block_on(async {
Expand Down

0 comments on commit 5a4c47f

Please sign in to comment.