test for concurrency

.github/workflows/up.yml

@@ -45,4 +45,4 @@ jobs:
           title: 'New version in README'
           assignees: yegor256
           branch: up
-          base: master
+          base: master

src/it/groovy/invoker.properties

@@ -26,4 +26,4 @@
 # ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
 # OF THE POSSIBILITY OF SUCH DAMAGE.
 
-invoker.goals = clean
+invoker.goals = clean

src/it/groovy/verify.groovy

@@ -35,4 +35,4 @@ def same = new XMLDocument(new File(basedir, 'same.xmir'))
 
 assert fist.equals(same)
 
-assert log.text.contains("BUILD SUCCESS")
+assert log.text.contains("BUILD SUCCESS")

src/main/java/com/jcabi/xml/XSLDocument.java

@@ -43,7 +43,6 @@
 import java.nio.file.Path;
 import java.util.HashMap;
 import java.util.Map;
-import java.util.concurrent.atomic.AtomicReference;
 import javax.xml.parsers.DocumentBuilder;
 import javax.xml.parsers.DocumentBuilderFactory;
 import javax.xml.parsers.ParserConfigurationException;

src/test/java/com/jcabi/xml/XSLDocumentTest.java

@@ -30,15 +30,15 @@
 package com.jcabi.xml;
 
 import com.jcabi.matchers.XhtmlMatchers;
-import java.util.concurrent.CountDownLatch;
+import com.yegor256.Together;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.TimeUnit;
-import java.util.concurrent.atomic.AtomicInteger;
 import org.apache.commons.lang3.StringUtils;
 import org.hamcrest.MatcherAssert;
 import org.hamcrest.Matchers;
 import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.RepeatedTest;
 import org.junit.jupiter.api.Test;
 
 /**
@@ -246,33 +246,22 @@ void catchesSaxonWarnings() {
         ).transform(new XMLDocument("<x><a/></x>"));
     }
 
-    @Test
+    @RepeatedTest(10)
     void transformsInManyThreads() throws Exception {
         final XSL xsl = new XSLDocument(
             this.getClass().getResourceAsStream("first.xsl")
         ).with(new ClasspathSources());
         final XML xml = new XMLDocument(
             this.getClass().getResourceAsStream("simple.xml")
         );
-        final AtomicInteger done = new AtomicInteger(0);
-        final CountDownLatch latch = new CountDownLatch(1);
         final int total = 50;
-        final ExecutorService exec = Executors.newFixedThreadPool(total);
-        for (int task = 0; task < total; ++task) {
-            exec.submit(
-                () -> {
-                    latch.await();
-                    xsl.transform(xml);
-                    xsl.transform(xml);
-                    done.incrementAndGet();
-                    return 0;
-                }
-            );
-        }
-        latch.countDown();
-        exec.shutdown();
-        exec.awaitTermination(1L, TimeUnit.MINUTES);
-        MatcherAssert.assertThat(done.get(), Matchers.equalTo(total));
+        MatcherAssert.assertThat(
+            new Together<>(
+                total,
+                t -> xsl.transform(xml)
+            ).asList().size(),
+            Matchers.equalTo(total)
+        );
     }
 
 }