import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;
import java.time.Duration;
import java.time.Instant;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

public class PlatformThreadTest {
    public static void main(String[] args) throws Exception {
        var client = HttpClient.newHttpClient();
        var request = HttpRequest.newBuilder()
                .uri(new URI("http://localhost:4000/"))
                .build();

        int totalRequests = 100000;
        int batchSize = 100;
        int numBatches = totalRequests / batchSize;

        Instant start = Instant.now();

        for (int batch = 0; batch < numBatches; batch++) {
            var executor = Executors.newFixedThreadPool(batchSize);
            CompletableFuture<?>[] futures = new CompletableFuture<?>[batchSize];

            for (int i = 0; i < batchSize; i++) {
                futures[i] = CompletableFuture.runAsync(() -> {
                    try {
                        HttpResponse<String> response = client.send(request, HttpResponse.BodyHandlers.ofString());
                        // System.out.println("Response code: " + response.statusCode());
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }, executor);
            }

            CompletableFuture.allOf(futures).join();
            executor.shutdown();
            executor.awaitTermination(1, TimeUnit.MINUTES);
        }

        Instant end = Instant.now();
        System.out.println("Time taken with platform threads: " + Duration.between(start, end).toMillis() + " ms");
    }
}