WebSocket Client with Configurable Thread Pool for Async Operations

To specify a thread pool configuration for the WebSocketClient's async executor, you can define a bean of type 'ThreadPoolTaskExecutor' with the desired configuration. Here's an example:

@Configuration
public class WebSocketConfig {

    @Bean(name = "websocketAsyncExecutor")
    public ThreadPoolTaskExecutor websocketAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(10); // Set the core pool size
        executor.setMaxPoolSize(20); // Set the maximum pool size
        executor.setQueueCapacity(100); // Set the queue capacity
        executor.setThreadNamePrefix("WebSocketAsync-"); // Set the thread name prefix
        executor.initialize();
        return executor;
    }
}

Then, in your WebSocketClient class, you can inject the 'websocketAsyncExecutor' bean using the '@Qualifier' annotation:

@Slf4j
@Component
public class WebSocketClient {

    @Autowired
    @Qualifier("websocketAsyncExecutor")
    private ThreadPoolTaskExecutor asyncExecutor;

    // ...

    public static WebSocket connection(final String url) {
        OkHttpClient client = new OkHttpClient.Builder()
                .readTimeout(5, TimeUnit.SECONDS)
                .dispatcher(new Dispatcher(asyncExecutor))
                .build();
        // ...
    }

    // ...
}

By specifying the 'websocketAsyncExecutor' bean as the dispatcher for the OkHttpClient, you can control the thread pool configuration for the WebSocketClient's async operations.