Spring/spring-grpc
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Use GrpcUtil to create shared executor

Browse Source
This commit is contained in:
Dave Syer
2025-01-07 16:39:19 +00:00
parent 6cc3a2ab89
commit d9731500fa
1 changed files with 4 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
spring-grpc-spring-boot-autoconfigure/src/main/java/org/springframework/grpc/autoconfigure/server/security/GrpcSecurityAutoConfiguration.java
View File

@@ -15,8 +15,6 @@
*/
package org.springframework.grpc.autoconfigure.server.security;
import java.util.concurrent.Executors;
import org.springframework.boot.autoconfigure.AutoConfiguration;
import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
@@ -31,12 +29,12 @@ import org.springframework.grpc.server.ServerBuilderCustomizer;
import org.springframework.grpc.server.exception.GrpcExceptionHandler;
import org.springframework.grpc.server.security.SecurityContextServerInterceptor;
import org.springframework.grpc.server.security.SecurityGrpcExceptionHandler;
import org.springframework.scheduling.concurrent.CustomizableThreadFactory;
import org.springframework.security.concurrent.DelegatingSecurityContextExecutor;
import org.springframework.security.config.ObjectPostProcessor;
import org.springframework.security.web.SecurityFilterChain;
import io.grpc.ServerBuilder;
import io.grpc.internal.GrpcUtil;
@ConditionalOnClass(ObjectPostProcessor.class)
@AutoConfiguration(before = GrpcExceptionHandlerAutoConfiguration.class, after = SecurityAutoConfiguration.class)
@@ -64,10 +62,9 @@ public class GrpcSecurityAutoConfiguration {
}
@Bean
public <T extends ServerBuilder<T>> ServerBuilderCustomizer<T> securityContextCustomizer() {
// TODO: configure the thread pool via GrpcServerProperties?
return (serverBuilder) -> serverBuilder.executor(new DelegatingSecurityContextExecutor(
Executors.newCachedThreadPool(new CustomizableThreadFactory("grpc-server-"))));
public <T extends ServerBuilder<T>> ServerBuilderCustomizer<T> securityContextExecutorCustomizer() {
return (serverBuilder) -> serverBuilder
.executor(new DelegatingSecurityContextExecutor(GrpcUtil.SHARED_CHANNEL_EXECUTOR.create()));
}
}