svn commit: r563499 - /xml/xindice/trunk/java/tests/src/org/apache/xindice/core/CollectionTest.java

Author: vgritsenko
Date: Tue Aug  7 06:44:56 2007
New Revision: 563499

URL: http://svn.apache.org/viewvc?view=rev&rev=563499
Log:
start all threads at once

Modified:
    xml/xindice/trunk/java/tests/src/org/apache/xindice/core/CollectionTest.java

Modified: xml/xindice/trunk/java/tests/src/org/apache/xindice/core/CollectionTest.java
URL: http://svn.apache.org/viewvc/xml/xindice/trunk/java/tests/src/org/apache/xindice/core/CollectionTest.java?view=diff&rev=563499&r1=563498&r2=563499
==============================================================================
--- xml/xindice/trunk/java/tests/src/org/apache/xindice/core/CollectionTest.java (original)
+++ xml/xindice/trunk/java/tests/src/org/apache/xindice/core/CollectionTest.java Tue Aug  7 06:44:56 2007
@@ -153,53 +153,61 @@
     }
 
     public void testConcurrentCreateCollection() throws Exception {
+        final int THREADS = 10;
         final String name = "create";
 
-        try {
-            final int THREADS = 10;
-            Thread[] threads = new Thread[THREADS];
-            final Counter count = new Counter();
-
-            for (int i = 0; i < THREADS; i++) {
+        final Object go = new Object();
+        final Counter count = new Counter();
 
-                threads[i] = new Thread() {
-                    public void run() {
+        Thread[] threads = new Thread[THREADS];
+        for (int i = 0; i < THREADS; i++) {
+            threads[i] = new Thread() {
+                public void run() {
+                    synchronized (go) {
                         try {
-                            db.createCollection(name, new Configuration(
-                                    DOMParser.toDocument(
-                                            "<collection  compressed='true' name='" + name + "' inline-metadata='true'>" +
-                                            "  <filer class='org.apache.xindice.core.filer.BTreeFiler' />" +
-                                            "</collection>"), false
-                            ));
-                        } catch (DBException e) {
-                            if (e.faultCode == FaultCodes.COL_DUPLICATE_COLLECTION) {
-                                count.incCount();
-                            } else {
-                                throw new RuntimeException("Failure: " + e);
-                            }
-                        } catch (XindiceException e) {
-                            // ignore
+                            go.wait();
+                        } catch (InterruptedException e) { /* ignored */ }
+                    }
+
+                    try {
+                        db.createCollection(name, new Configuration(
+                                DOMParser.toDocument(
+                                        "<collection  compressed='true' name='" + name + "' inline-metadata='true'>" +
+                                        "  <filer class='org.apache.xindice.core.filer.BTreeFiler' />" +
+                                        "</collection>"), false
+                        ));
+                    } catch (DBException e) {
+                        if (e.faultCode == FaultCodes.COL_DUPLICATE_COLLECTION) {
+                            count.incCount();
+                        } else {
+                            throw new RuntimeException("Failure: " + e);
                         }
+                    } catch (XindiceException e) {
+                        // ignore
                     }
-                };
-            }
+                }
+            };
+            threads[i].setName("CollectionTest" + i);
+            threads[i].start();
+        }
 
-            for (int i = 0; i < THREADS; i++) {
-                threads[i].start();
+        try {
+            // Start all the threads at once
+            Thread.sleep(250);
+            synchronized (go) {
+                go.notifyAll();
             }
-
             for (int i = 0; i < THREADS; i++) {
                 threads[i].join();
             }
-
-            assertEquals(THREADS - 1, count.getCount());
-
         } finally {
             Collection col = db.getCollection(name);
-                if (col != null) {
-                    db.dropCollection(col);
-                }
+            if (col != null) {
+                db.dropCollection(col);
+            }
         }
+
+        assertEquals(THREADS - 1, count.getCount());
     }
 
     private class Counter {