From d2bac514afd9dd06c4c2da3c50cc2442afebb8ed Mon Sep 17 00:00:00 2001
From: leventov <leventov@ya.ru>
Date: Mon, 8 Jun 2015 18:14:03 +0300
Subject: [PATCH] Fix compilation level to 1.7 in tests

---
 .../map/ChronicleMapSanityCheckTest.java      | 61 ++++++++++---------
 1 file changed, 32 insertions(+), 29 deletions(-)

diff --git a/src/test/java/net/openhft/chronicle/map/ChronicleMapSanityCheckTest.java b/src/test/java/net/openhft/chronicle/map/ChronicleMapSanityCheckTest.java
index 2706a4b08..bad05ab89 100644
--- a/src/test/java/net/openhft/chronicle/map/ChronicleMapSanityCheckTest.java
+++ b/src/test/java/net/openhft/chronicle/map/ChronicleMapSanityCheckTest.java
@@ -56,7 +56,7 @@ public class ChronicleMapSanityCheckTest {
         ScheduledExecutorService consumerExecutor =
                 Executors.newSingleThreadScheduledExecutor();
 
-        int N = 1000;
+        final int N = 1000;
 
         int producerPeriod = 100;
         TimeUnit producerTimeUnit = TimeUnit.MILLISECONDS;
@@ -73,45 +73,48 @@ public class ChronicleMapSanityCheckTest {
 
             map.clear();
 
-            producerExecutor.scheduleAtFixedRate(() -> {
+            producerExecutor.scheduleAtFixedRate(new Runnable() {
+                @Override
+                public void run() {
+                    Thread.currentThread().setName("Producer " + Thread.currentThread().getId());
+                    Random r = new Random();
 
-                Thread.currentThread().setName("Producer " + Thread.currentThread().getId());
-                Random r = new Random();
-
-                System.out.println("Before PRODUCING size is " + map.size());
-                for (int i = 0; i < N; i++) {
-                    LockSupport.parkNanos(r.nextInt(5));
-                    map.put(String.valueOf(i), DummyValue.DUMMY_VALUE);
+                    System.out.println("Before PRODUCING size is " + map.size());
+                    for (int i = 0; i < N; i++) {
+                        LockSupport.parkNanos(r.nextInt(5));
+                        map.put(String.valueOf(i), DummyValue.DUMMY_VALUE);
+                    }
+                    System.out.println("After PRODUCING size is " + map.size());
                 }
-                System.out.println("After PRODUCING size is " + map.size());
-
             }, 0, producerPeriod, producerTimeUnit);
 
-            consumerExecutor.scheduleAtFixedRate(() -> {
+            consumerExecutor.scheduleAtFixedRate(new Runnable() {
+                @Override
+                public void run() {
+                    Thread.currentThread().setName("Consumer");
+                    Set<String> keys = map.keySet();
 
-                Thread.currentThread().setName("Consumer");
-                Set<String> keys = map.keySet();
+                    Random r = new Random();
 
-                Random r = new Random();
-
-                System.out.println("Before CONSUMING size is " + map.size());
-                System.out.println();
-                for (String key : keys) {
-                    if (r.nextBoolean()) {
-                        map.remove(key);
+                    System.out.println("Before CONSUMING size is " + map.size());
+                    System.out.println();
+                    for (String key : keys) {
+                        if (r.nextBoolean()) {
+                            map.remove(key);
+                        }
                     }
+
+                    System.out.println("After CONSUMING size is " + map.size());
+
                 }
+            }, 0, consumerPeriod,consumerTimeUnit);
 
-                System.out.println("After CONSUMING size is " + map.size());
+                Thread.sleep(totalTestTimeMS);
 
-            }, 0, consumerPeriod, consumerTimeUnit);
+                consumerExecutor.shutdown();
+                producerExecutor.shutdown();
+            }
 
-            Thread.sleep(totalTestTimeMS);
-
-            consumerExecutor.shutdown();
-            producerExecutor.shutdown();
         }
 
-    }
-
 }