wip

Author: jenschude

commercetools/commercetools-sdk-java-api/build.gradle

@@ -36,6 +36,13 @@ tasks.register('runMainMethodMemoryLeakTest', JavaExec) {
     maxHeapSize("128m")
 }
 
+tasks.register('runLongRunningTimeoutTest', JavaExec) {
+    group = "Execution"
+    description = "Run the main method thread leak test class"
+    classpath = sourceSets.test.runtimeClasspath
+    mainClass = "com.commercetools.LongRunningTimeoutTest"
+    maxHeapSize("128m")
+}
 
 apply plugin: com.commercetools.sdk.plugins.MigrationInfoPlugin
 

commercetools/commercetools-sdk-java-api/src/test/java/com/commercetools/LongRunningTimeoutTest.java

@@ -54,7 +54,7 @@ public static void main(String[] args) throws InterruptedException, ExecutionExc
         final int elements = 100000;
         BlockingQueue<Pair<String, Integer>> blockingQueue = new ArrayBlockingQueue<>(50000);
 
-        final int concurrency = 20;
+        final int concurrency = 100;
         ExecutorService threadPool = Executors.newFixedThreadPool(concurrency);
 
         Random r = new Random();
@@ -83,26 +83,32 @@ public static void main(String[] args) throws InterruptedException, ExecutionExc
                 //                .protocols(Lists.list(Protocol.HTTP_1_1))
                 .build();
         for (int i = 0; i < concurrency; i++) {
+            int finalI = i;
             threadPool.execute(() -> {
                 try {
                     while (!threadPool.isTerminated()) {
                         Pair<String, Integer> p = blockingQueue.poll(1, TimeUnit.SECONDS);
                         if (p == null) {
                             break;
                         }
-                        //                        final Request request = new Request.Builder()
-                        //                                .addHeader("Authorization", "Bearer " + token.getAccessToken())
-                        //                                .addHeader("Content-Type", "application/json")
-                        //                                .url(ServiceRegion.GCP_EUROPE_WEST1.getApiUrl() + "/" + getProjectKey() + "/messages/"
-                        //                                        + p.getLeft())
-                        //                                .build();
-                        //                        try (Response response = client2.newCall(request).execute()) {
-                        //                            String b = response.body().string();
-                        //                            response.close();
-                        //                            System.out.println(b);
-                        //                            System.out.println(p.getRight());
-                        //                            System.out.println(client2.dispatcher().runningCallsCount());
-                        //                        }
+                        final Request request = new Request.Builder()
+                                //                                .addHeader("Authorization", "Bearer " + token.getAccessToken())
+                                //                                .addHeader("Content-Type", "application/json")
+                                .url("https://jsonapi.org/")
+                                .get()
+                                .build();
+                        try (Response response = client2.newCall(request).execute()) {
+                            String b = response.body().string();
+                            response.body().close();
+                            response.close();
+                            System.out.println("i: " + p.getRight() + "\ts: " + response.code() + "\tr: "
+                                    + client2.dispatcher().runningCallsCount() + "\tc: "
+                                    + client2.connectionPool().idleConnectionCount() + "; "
+                                    + client2.connectionPool().connectionCount());
+                        }
+                        catch (IOException e) {
+                            throw new RuntimeException(e);
+                        }
 
                         final ApiHttpResponse<byte[]> messageApiHttpResponse = client.withProjectKey(getProjectKey())
                                 .messages()