|
|
@@ -1,12 +1,10 @@
|
|
|
package com.vber.common.core.config;
|
|
|
|
|
|
-import com.vber.common.core.config.properties.ThreadPoolProperties;
|
|
|
import com.vber.common.core.utils.SpringUtils;
|
|
|
import jakarta.annotation.PreDestroy;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.apache.commons.lang3.concurrent.BasicThreadFactory;
|
|
|
import org.springframework.boot.autoconfigure.AutoConfiguration;
|
|
|
-import org.springframework.boot.context.properties.EnableConfigurationProperties;
|
|
|
import org.springframework.context.annotation.Bean;
|
|
|
import org.springframework.core.task.VirtualThreadTaskExecutor;
|
|
|
|
|
|
@@ -19,7 +17,6 @@ import java.util.concurrent.*;
|
|
|
**/
|
|
|
@Slf4j
|
|
|
@AutoConfiguration
|
|
|
-@EnableConfigurationProperties(ThreadPoolProperties.class)
|
|
|
public class ThreadPoolConfig {
|
|
|
/**
|
|
|
* 核心线程数 = cpu 核心数 + 1
|
|
|
@@ -59,7 +56,8 @@ public class ThreadPoolConfig {
|
|
|
// daemon 必须为 true
|
|
|
BasicThreadFactory.Builder builder = new BasicThreadFactory.Builder().daemon(true);
|
|
|
if (SpringUtils.isVirtual()) {
|
|
|
- builder.namingPattern("virtual-schedule-pool-%d").wrappedFactory(new VirtualThreadTaskExecutor().getVirtualThreadFactory());
|
|
|
+ builder.namingPattern("virtual-schedule-pool-%d")
|
|
|
+ .wrappedFactory(new VirtualThreadTaskExecutor().getVirtualThreadFactory());
|
|
|
} else {
|
|
|
builder.namingPattern("schedule-pool-%d");
|
|
|
}
|