BUG-7464: Update pom.xml

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

diff --git a/third-party/triemap/src/test/java/com/romix/scala/collection/concurrent/TestMultiThreadAddDelete.java b/third-party/triemap/src/test/java/org/opendaylight/yangtools/triemap/TestMultiThreadAddDelete.java
similarity index 96%
rename from third-party/triemap/src/test/java/com/romix/scala/collection/concurrent/TestMultiThreadAddDelete.java
rename to third-party/triemap/src/test/java/org/opendaylight/yangtools/triemap/TestMultiThreadAddDelete.java
index 99280c208f26fa37e7f8b9fac45822010f684252..efcb846a9b63b4323af6cfcf222fa722407fd7e7 100644 (file)
--- a/third-party/triemap/src/test/java/com/romix/scala/collection/concurrent/TestMultiThreadAddDelete.java
+++ b/third-party/triemap/src/test/java/org/opendaylight/yangtools/triemap/TestMultiThreadAddDelete.java
@@ -1,114 +1,114 @@
-package com.romix.scala.collection.concurrent;\r
-\r
-import java.util.Map;\r
-import java.util.concurrent.ExecutorService;\r
-import java.util.concurrent.Executors;\r
-import java.util.concurrent.TimeUnit;\r
-\r
-import org.junit.Test;\r
-\r
-public class TestMultiThreadAddDelete {\r
-    private static final int RETRIES = 1;\r
-    private static final int N_THREADS = 7;\r
-    private static final int COUNT =  50 * 1000;\r
-\r
-    @Test\r
-    public void testMultiThreadAddDelete () {\r
-        for (int j = 0; j < RETRIES; j++) {\r
-            final Map<Object, Object> bt = new TrieMap <Object, Object> ();\r
-            \r
-            {\r
-                final ExecutorService es = Executors.newFixedThreadPool (N_THREADS);\r
-                for (int i = 0; i < N_THREADS; i++) {\r
-                    final int threadNo = i;\r
-                    es.execute (new Runnable () {\r
-                        @Override\r
-                        public void run () {\r
-                            for (int j = 0; j < COUNT; j++) {\r
-                                if (j % N_THREADS == threadNo) {\r
-                                    bt.put (Integer.valueOf (j), Integer.valueOf (j));\r
-                                }\r
-                            }\r
-                        }\r
-                    });\r
-                }\r
-                es.shutdown ();\r
-                try {\r
-                    es.awaitTermination (3600L, TimeUnit.SECONDS);\r
-                } catch (final InterruptedException e) {\r
-                    e.printStackTrace ();\r
-                }\r
-            }\r
-            \r
-            TestHelper.assertEquals (COUNT, bt.size ());\r
-            TestHelper.assertFalse (bt.isEmpty ());\r
-            \r
-            {\r
-                final ExecutorService es = Executors.newFixedThreadPool (N_THREADS);\r
-                for (int i = 0; i < N_THREADS; i++) {\r
-                    final int threadNo = i;\r
-                    es.execute (new Runnable () {\r
-                        @Override\r
-                        public void run () {\r
-                            for (int j = 0; j < COUNT; j++) {\r
-                                if (j % N_THREADS == threadNo) {\r
-                                    bt.remove (Integer.valueOf (j));\r
-                                }\r
-                            }\r
-                        }\r
-                    });\r
-                }\r
-                es.shutdown ();\r
-                try {\r
-                    es.awaitTermination (3600L, TimeUnit.SECONDS);\r
-                } catch (final InterruptedException e) {\r
-                    e.printStackTrace ();\r
-                }\r
-            }\r
-            \r
-            \r
-            TestHelper.assertEquals (0, bt.size ());\r
-            TestHelper.assertTrue (bt.isEmpty ());\r
-            \r
-            {\r
-                final ExecutorService es = Executors.newFixedThreadPool (N_THREADS);\r
-                for (int i = 0; i < N_THREADS; i++) {\r
-                    final int threadNo = i;\r
-                    es.execute (new Runnable () {\r
-                        @Override\r
-                        public void run () {\r
-                            for (int j = 0; j < COUNT; j++) {\r
-                                if (j % N_THREADS == threadNo) {\r
-                                    try {\r
-                                        bt.put (Integer.valueOf (j), Integer.valueOf (j));\r
-                                        if (!bt.containsKey (Integer.valueOf (j))) {\r
-                                            System.out.println (j);\r
-                                        }\r
-                                        bt.remove (Integer.valueOf (j));\r
-                                        if (bt.containsKey (Integer.valueOf (j))) {\r
-                                            System.out.println (-j);\r
-                                        }\r
-                                    } catch (Throwable t) {\r
-                                        t.printStackTrace ();\r
-                                    }\r
-                                }\r
-                            }\r
-                        }\r
-                    });\r
-                }\r
-                es.shutdown ();\r
-                try {\r
-                    es.awaitTermination (3600L, TimeUnit.SECONDS);\r
-                } catch (final InterruptedException e) {\r
-                    e.printStackTrace ();\r
-                }\r
-            }\r
-            \r
-            TestHelper.assertEquals (0, bt.size ());\r
-            if (!bt.isEmpty ()) {\r
-                System.out.println ();\r
-            }\r
-            TestHelper.assertTrue (bt.isEmpty ());\r
-        }\r
-    }\r
-}\r
+package org.opendaylight.yangtools.triemap;
+
+import java.util.Map;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.TimeUnit;
+
+import org.junit.Test;
+
+public class TestMultiThreadAddDelete {
+    private static final int RETRIES = 1;
+    private static final int N_THREADS = 7;
+    private static final int COUNT =  50 * 1000;
+
+    @Test
+    public void testMultiThreadAddDelete () {
+        for (int j = 0; j < RETRIES; j++) {
+            final Map<Object, Object> bt = new TrieMap <Object, Object> ();
+            
+            {
+                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) {
+                                    bt.put (Integer.valueOf (j), Integer.valueOf (j));
+                                }
+                            }
+                        }
+                    });
+                }
+                es.shutdown ();
+                try {
+                    es.awaitTermination (3600L, TimeUnit.SECONDS);
+                } catch (final InterruptedException e) {
+                    e.printStackTrace ();
+                }
+            }
+            
+            TestHelper.assertEquals (COUNT, bt.size ());
+            TestHelper.assertFalse (bt.isEmpty ());
+            
+            {
+                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) {
+                                    bt.remove (Integer.valueOf (j));
+                                }
+                            }
+                        }
+                    });
+                }
+                es.shutdown ();
+                try {
+                    es.awaitTermination (3600L, TimeUnit.SECONDS);
+                } catch (final InterruptedException e) {
+                    e.printStackTrace ();
+                }
+            }
+            
+            
+            TestHelper.assertEquals (0, bt.size ());
+            TestHelper.assertTrue (bt.isEmpty ());
+            
+            {
+                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.shutdown ();
+                try {
+                    es.awaitTermination (3600L, TimeUnit.SECONDS);
+                } catch (final InterruptedException e) {
+                    e.printStackTrace ();
+                }
+            }
+            
+            TestHelper.assertEquals (0, bt.size ());
+            if (!bt.isEmpty ()) {
+                System.out.println ();
+            }
+            TestHelper.assertTrue (bt.isEmpty ());
+        }
+    }
+}