lbqms.git - Gitblit

			@@ -2,14 +2,15 @@

			import jakarta.annotation.PreDestroy;
			import lombok.extern.slf4j.Slf4j;
			import org.dromara.common.core.config.properties.ThreadPoolProperties;
			import org.dromara.common.core.utils.Threads;
			import org.apache.commons.lang3.concurrent.BasicThreadFactory;
			import org.springframework.beans.factory.annotation.Qualifier;
			import org.dromara.common.core.config.properties.ThreadPoolProperties;
			import org.dromara.common.core.utils.SpringUtils;
			import org.dromara.common.core.utils.Threads;
			import org.springframework.boot.autoconfigure.AutoConfiguration;
			import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
			import org.springframework.boot.context.properties.EnableConfigurationProperties;
			import org.springframework.context.annotation.Bean;
			import org.springframework.core.task.VirtualThreadTaskExecutor;
			import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

			import java.util.concurrent.ScheduledExecutorService;
			@@ -31,6 +32,8 @@
			*/
			private final int core = Runtime.getRuntime().availableProcessors() + 1;

			private ScheduledExecutorService scheduledExecutorService;

			@Bean(name = "threadPoolTaskExecutor")
			@ConditionalOnProperty(prefix = "thread-pool", name = "enabled", havingValue = "true")
			public ThreadPoolTaskExecutor threadPoolTaskExecutor(ThreadPoolProperties threadPoolProperties) {
			@@ -48,8 +51,15 @@
			*/
			@Bean(name = "scheduledExecutorService")
			protected ScheduledExecutorService scheduledExecutorService() {
			return new ScheduledThreadPoolExecutor(core,
			new BasicThreadFactory.Builder().namingPattern("schedule-pool-%d").daemon(true).build(),
			// daemon 必须为 true
			BasicThreadFactory.Builder builder = new BasicThreadFactory.Builder().daemon(true);
			if (SpringUtils.isVirtual()) {
			builder.namingPattern("virtual-schedule-pool-%d").wrappedFactory(new VirtualThreadTaskExecutor().getVirtualThreadFactory());
			} else {
			builder.namingPattern("schedule-pool-%d");
			}
			ScheduledThreadPoolExecutor scheduledThreadPoolExecutor = new ScheduledThreadPoolExecutor(core,
			builder.build(),
			new ThreadPoolExecutor.CallerRunsPolicy()) {
			@Override
			protected void afterExecute(Runnable r, Throwable t) {
			@@ -57,13 +67,15 @@
			Threads.printException(r, t);
			}
			};
			this.scheduledExecutorService = scheduledThreadPoolExecutor;
			return scheduledThreadPoolExecutor;
			}

			/**
			* 销毁事件
			*/
			@PreDestroy
			public void destroy(@Qualifier("scheduledExecutorService") ScheduledExecutorService scheduledExecutorService) {
			public void destroy() {
			try {
			log.info("====关闭后台任务任务线程池====");
			Threads.shutdownAndAwaitTermination(scheduledExecutorService);