blam, multi-threaded client based on thread_id

CrescoEdge · Feb 21, 2024 · f1099c5 · f1099c5
1 parent 47d1fed
commit f1099c5
Showing 1 changed file with 11 additions and 2 deletions.
diff --git a/src/main/java/example/TextPerformanceTesting.java b/src/main/java/example/TextPerformanceTesting.java
@@ -94,13 +94,17 @@ public void onMessage(byte[] b, int offset, int length) {
                 Thread.sleep(1000);
             }
 
+            Thread.sleep(5000);
+
+
             String input = "BRRRRUUU";
 
-            for(int i = 0; i<50; i++) {
+            for(int i = 0; i<10; i++) {
                launchThread(dataPlaneSend, input);
             }
 
             while(true) {
+            //for(int i = 0; i<25; i++) {
                 Thread.sleep(1000);
                 //dataPlaneSend.send(str);
             }
@@ -118,7 +122,12 @@ private void launchThread(DataPlaneInterface dataPlaneSend, String input) {
             public void run() {
                 try {
                     while(true) {
-                        dataPlaneSend.send(input);
+                        for(int i = 0; i<100; i++) {
+                            //Thread.sleep(1000);
+                            //dataPlaneSend.send(str);
+                            dataPlaneSend.send(input);
+                        }
+                        //dataPlaneSend.send(input);
                         //Thread.sleep(1000);
                     }