Fix dead lock in tests

Author: Artem Labazin

benchmark/src/main/java/io/appulse/encon/benchmark/Encon_SimpleBenchmarks.java

@@ -122,8 +122,6 @@ public static class OneDirectionSendState {
 
     ErlangPid serverMailboxPid;
 
-    Thread serverThread;
-
     Node clientNode;
 
     Mailbox clientMailbox;
@@ -145,16 +143,6 @@ public void setup () throws Exception {
       serverMailbox = serverNode.mailbox().build();
       serverMailboxPid = serverMailbox.getPid();
 
-      serverThread = new Thread(() -> {
-          try {
-            while (!java.lang.Thread.interrupted()) {
-              serverMailbox.receive();
-            }
-          } catch (Throwable ex) {
-          }
-      });
-      serverThread.start();
-
       clientNode = Nodes.singleNode("node-client-" + System.nanoTime(), config);
       clientMailbox = clientNode.mailbox().build();
 
@@ -168,8 +156,6 @@ public void tearDown () {
 
       serverMailbox.close();
       serverNode.close();
-
-      serverThread.interrupt();
     }
   }
 }

benchmark/src/main/java/io/appulse/encon/benchmark/JInterface_SimpleBenchmarks.java

@@ -107,8 +107,6 @@ public static class OneDirectionSendState {
 
     OtpErlangPid serverMailboxPid;
 
-    Thread serverThread;
-
     OtpNode clientNode;
 
     OtpMbox clientMailbox;
@@ -121,16 +119,6 @@ public void setup () throws Exception {
       serverMailbox = serverNode.createMbox();
       serverMailboxPid = serverMailbox.self();
 
-      serverThread = new Thread(() -> {
-          try {
-            while (!java.lang.Thread.interrupted()) {
-              serverMailbox.receive();
-            }
-          } catch (Throwable ex) {
-          }
-      });
-      serverThread.start();
-
       clientNode = new OtpNode("node-client-" + System.nanoTime() + "@localhost");
       clientMailbox = clientNode.createMbox();
 
@@ -144,8 +132,6 @@ public void tearDown () {
 
       serverMailbox.close();
       serverNode.close();
-
-      serverThread.interrupt();
     }
   }
 }