Migrate to tech.pantheon.TrieMap

[yangtools.git] / third-party / triemap / src / test / java / org / opendaylight / yangtools / triemap / TestMultiThreadAddDelete.java

diff --git a/third-party/triemap/src/test/java/org/opendaylight/yangtools/triemap/TestMultiThreadAddDelete.java b/third-party/triemap/src/test/java/org/opendaylight/yangtools/triemap/TestMultiThreadAddDelete.java
index 71034c7a0c77e6dd8ac9450e13129347dd906ec1..bbfe70ed3def695638dccb8ca8039a9cbd8cff96 100644 (file)
--- a/third-party/triemap/src/test/java/org/opendaylight/yangtools/triemap/TestMultiThreadAddDelete.java
+++ b/third-party/triemap/src/test/java/org/opendaylight/yangtools/triemap/TestMultiThreadAddDelete.java
@@ -24,14 +24,18 @@ import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.TimeUnit;
 import org.junit.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
+@Deprecated
 public class TestMultiThreadAddDelete {
+    private static final Logger LOG = LoggerFactory.getLogger(TestMultiThreadAddDelete.class);
     private static final int RETRIES = 1;
     private static final int N_THREADS = 7;
     private static final int COUNT = 50 * 1000;
 
     @Test
-    public void testMultiThreadAddDelete () throws InterruptedException {
+    public void testMultiThreadAddDelete() throws InterruptedException {
         for (int j = 0; j < RETRIES; j++) {
             final Map<Object, Object> bt = TrieMap.create();
 
@@ -47,7 +51,7 @@ public class TestMultiThreadAddDelete {
                         }
                     });
                 }
-                es.shutdown ();
+                es.shutdown();
                 es.awaitTermination(5, TimeUnit.MINUTES);
             }
 
@@ -58,49 +62,42 @@ public class TestMultiThreadAddDelete {
                 final ExecutorService es = Executors.newFixedThreadPool(N_THREADS);
                 for (int i = 0; i < N_THREADS; i++) {
                     final int threadNo = i;
-                    es.execute (() -> {
+                    es.execute(() -> {
                         for (int k = 0; k < COUNT; k++) {
                             if (k % N_THREADS == threadNo) {
-                                bt.remove (Integer.valueOf (k));
+                                bt.remove(Integer.valueOf(k));
                             }
                         }
                     });
                 }
-                es.shutdown ();
+                es.shutdown();
                 es.awaitTermination(5, TimeUnit.MINUTES);
             }
 
 
-            assertEquals(0, bt.size ());
+            assertEquals(0, bt.size());
             assertTrue(bt.isEmpty());
 
             {
-                final ExecutorService es = Executors.newFixedThreadPool (N_THREADS);
+                final ExecutorService es = Executors.newFixedThreadPool(N_THREADS);
                 for (int i = 0; i < N_THREADS; i++) {
                     final int threadNo = i;
-                    es.execute (new Runnable () {
-                        @Override
-                        public void run () {
-                            for (int j = 0; j < COUNT; j++) {
-                                if (j % N_THREADS == threadNo) {
-                                    try {
-                                        bt.put (Integer.valueOf (j), Integer.valueOf (j));
-                                        if (!bt.containsKey (Integer.valueOf (j))) {
-                                            System.out.println (j);
-                                        }
-                                        bt.remove (Integer.valueOf (j));
-                                        if (bt.containsKey (Integer.valueOf (j))) {
-                                            System.out.println (-j);
-                                        }
-                                    } catch (Throwable t) {
-                                        t.printStackTrace ();
-                                    }
+                    es.execute(() -> {
+                        for (int j1 = 0; j1 < COUNT; j1++) {
+                            if (j1 % N_THREADS == threadNo) {
+                                bt.put(Integer.valueOf(j1), Integer.valueOf(j1));
+                                if (!bt.containsKey(Integer.valueOf(j1))) {
+                                    LOG.error("Key {} not present", j1);
+                                }
+                                bt.remove(Integer.valueOf(j1));
+                                if (bt.containsKey(Integer.valueOf(j1))) {
+                                    LOG.error("Key {} is still present", j1);
                                 }
                             }
                         }
                     });
                 }
-                es.shutdown ();
+                es.shutdown();
                 es.awaitTermination(5, TimeUnit.MINUTES);
             }