Class ExecutorConfiguration

java.lang.Object

com.github._1c_syntax.bsl.languageserver.infrastructure.ExecutorConfiguration

@Configuration
@EnableAsync(proxyTargetClass=true)
public class ExecutorConfiguration
extends Object

Конфигурация исполнителей для обработки асинхронных задач.

ForkJoinPool-исполнители (в которых запускаются parallelStream()) создаются per-workspace — каждый воркспейс получает свой набор пулов. Worker threads устанавливают workspace URI в ThreadLocal при старте (onStart()), что гарантирует корректную работу workspace-scoped proxy в fork-задачах. Там же воркер получает своё имя — до регистрации в пуле его индекс ещё не известен.

Исключение: computeConfigurationExecutor — singleton, т.к. вызывает внешнюю библиотеку MDClasses, не использующую ThreadLocal из BSL LS.

Остальные исполнители — короткоживущие обработчики запросов LSP без parallelStream() внутри — реализуются через SimpleAsyncTaskExecutor в режиме виртуальных потоков (setVirtualThreads(true)) с TaskDecorator для прокидывания контекста.

Методы с @Async исполняются на исполнителе, названном в аннотации. Исполнитель по умолчанию не настроен: @Async без имени ушёл бы на исполнитель, который Spring выберет сам, и без контекста workspace.

Constructor Summary

Constructors

Constructor	Description
ExecutorConfiguration()

Method Summary

Modifier and Type	Method	Description
ExecutorService	analyzeOnStartExecutor()
AsyncTaskExecutor	asyncEventListenerExecutor(TaskDecorator compositeTaskDecorator)
ExecutorService	cliExecutor()
TaskDecorator	compositeTaskDecorator(io.sentry.spring7.SentryTaskDecorator sentryDecorator, TaskDecorator contextPropagatingDecorator)
ExecutorService	computeConfigurationExecutor()
ContextPropagatingTaskDecorator	contextPropagatingDecorator()
ExecutorService	diagnosticComputerExecutor()
AsyncTaskExecutor	platformTypesWarmupExecutor(TaskDecorator compositeTaskDecorator)
ExecutorService	populateContextExecutor()
ExecutorService	resolveReturnTypesExecutor()
ExecutorService	semanticTokensExecutor()
io.sentry.spring7.SentryTaskDecorator	sentryDecorator()
AsyncTaskExecutor	sentryExecutor(TaskDecorator compositeTaskDecorator)
AsyncTaskExecutor	textDocumentServiceExecutor(TaskDecorator compositeTaskDecorator)
AsyncTaskExecutor	workspaceServiceExecutor(TaskDecorator compositeTaskDecorator)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ExecutorConfiguration

public ExecutorConfiguration()

Method Details

sentryDecorator

@Bean
public io.sentry.spring7.SentryTaskDecorator sentryDecorator()

contextPropagatingDecorator

@Bean
public ContextPropagatingTaskDecorator contextPropagatingDecorator()

compositeTaskDecorator

@Bean
public TaskDecorator compositeTaskDecorator(io.sentry.spring7.SentryTaskDecorator sentryDecorator,
 TaskDecorator contextPropagatingDecorator)

textDocumentServiceExecutor

@Bean
public AsyncTaskExecutor textDocumentServiceExecutor(TaskDecorator compositeTaskDecorator)

workspaceServiceExecutor

@Bean
public AsyncTaskExecutor workspaceServiceExecutor(TaskDecorator compositeTaskDecorator)

platformTypesWarmupExecutor

@Bean
public AsyncTaskExecutor platformTypesWarmupExecutor(TaskDecorator compositeTaskDecorator)

sentryExecutor

@Bean
public AsyncTaskExecutor sentryExecutor(TaskDecorator compositeTaskDecorator)

asyncEventListenerExecutor

@Bean
public AsyncTaskExecutor asyncEventListenerExecutor(TaskDecorator compositeTaskDecorator)

populateContextExecutor

@Bean(destroyMethod="shutdown")
@WorkspaceScope(proxyMode=INTERFACES)
public ExecutorService populateContextExecutor()

resolveReturnTypesExecutor

@Bean(destroyMethod="shutdown")
@WorkspaceScope(proxyMode=INTERFACES)
public ExecutorService resolveReturnTypesExecutor()

computeConfigurationExecutor

@Bean(destroyMethod="shutdown")
public ExecutorService computeConfigurationExecutor()

diagnosticComputerExecutor

@Bean(destroyMethod="shutdown")
@WorkspaceScope(proxyMode=INTERFACES)
public ExecutorService diagnosticComputerExecutor()

analyzeOnStartExecutor

@Bean(destroyMethod="shutdown")
@WorkspaceScope(proxyMode=INTERFACES)
public ExecutorService analyzeOnStartExecutor()

semanticTokensExecutor

@Bean(destroyMethod="shutdown")
@WorkspaceScope(proxyMode=INTERFACES)
public ExecutorService semanticTokensExecutor()

cliExecutor

@Bean(destroyMethod="shutdown")
@WorkspaceScope(proxyMode=INTERFACES)
public ExecutorService cliExecutor()