Add JMH to functional tests iterating over threads (fibers)

pom.xml

@@ -398,6 +398,12 @@
             <artifactId>url-connection-client</artifactId>
             <version>${aws-sdk.version}</version>
         </dependency>
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter-params</artifactId>
+            <version>5.10.0</version>
+            <scope>test</scope>
+        </dependency>
     </dependencies>
 
     <repositories>

src/test/java/edu/illinois/library/cantaloupe/cache/AbstractCacheTest.java

@@ -12,6 +12,8 @@
 import edu.illinois.library.cantaloupe.test.TestUtil;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.params.ParameterizedTest;
+import org.junit.jupiter.params.provider.ValueSource;
 
 import java.io.ByteArrayOutputStream;
 import java.io.IOException;
@@ -188,8 +190,9 @@ void testNewDerivativeImageInputStreamWithNonexistentImage()
         assertNotExists(instance, ops);
     }
 
-    @Test
-    void testNewDerivativeImageInputStreamConcurrently() throws Exception {
+    @ParameterizedTest
+    @ValueSource(ints = {500})
+    void testNewDerivativeImageInputStreamConcurrently(int numThreads) throws Exception {
         final DerivativeCache instance = newInstance();
         final OperationList ops = OperationList.builder()
                 .withIdentifier(new Identifier("cats"))
@@ -213,7 +216,7 @@ void testNewDerivativeImageInputStreamConcurrently() throws Exception {
                 }
             }
             return null;
-        }).run();
+        }, numThreads).run();
     }
 
     /* newDerivativeImageOutputStream() */
@@ -559,8 +562,9 @@ void testPutWithInfo() throws Exception {
      * DerivativeCache#put(Identifier, Info)} and {@link
      * DerivativeCache#getInfo(Identifier)} don't conflict.
      */
-    @Test
-    void testPutWithInfoConcurrently() throws Exception {
+    @ParameterizedTest
+    @ValueSource(ints = {500})
+    void testPutWithInfoConcurrently(int numThreads) throws Exception {
         final DerivativeCache instance = newInstance();
         final Identifier identifier    = new Identifier("monkeys");
         final Info info                = new Info();
@@ -574,7 +578,7 @@ void testPutWithInfoConcurrently() throws Exception {
                 fail();
             }
             return null;
-        }).run();
+        }, numThreads).run();
     }
 
     @Test
@@ -610,8 +614,9 @@ void testPutWithString() throws Exception {
      * DerivativeCache#put(Identifier, String)} and {@link
      * DerivativeCache#getInfo(Identifier)} don't conflict.
      */
-    @Test
-    void testPutWithStringConcurrently() throws Exception {
+    @ParameterizedTest
+    @ValueSource(ints = {500})
+    void testPutWithStringConcurrently(int numThreads) throws Exception {
         final DerivativeCache instance = newInstance();
         final Identifier identifier    = new Identifier("monkeys");
         final Info info                = new Info();
@@ -626,7 +631,7 @@ void testPutWithStringConcurrently() throws Exception {
                 fail();
             }
             return null;
-        }).run();
+        }, numThreads).run();
     }
 
 }

src/test/java/edu/illinois/library/cantaloupe/cache/FilesystemCacheTest.java

@@ -36,15 +36,42 @@
 import static org.junit.jupiter.api.Assertions.*;
 import static org.junit.jupiter.api.Assumptions.assumeFalse;
 
+import java.util.concurrent.TimeUnit;
+import org.openjdk.jmh.annotations.Benchmark;
+import org.openjdk.jmh.annotations.BenchmarkMode;
+import org.openjdk.jmh.annotations.Fork;
+import org.openjdk.jmh.annotations.Measurement;
+import org.openjdk.jmh.annotations.Mode;
+import org.openjdk.jmh.annotations.OutputTimeUnit;
+import org.openjdk.jmh.annotations.Param;
+import org.openjdk.jmh.annotations.Scope;
+import org.openjdk.jmh.annotations.Setup;
+import org.openjdk.jmh.annotations.State;
+import org.openjdk.jmh.annotations.TearDown;
+import org.openjdk.jmh.annotations.Warmup;
+import static edu.illinois.library.cantaloupe.test.PerformanceTestConstants.*;
+
+@BenchmarkMode(Mode.AverageTime)
+@OutputTimeUnit(TimeUnit.MICROSECONDS)
+@Warmup(iterations = WARMUP_ITERATIONS,
+        time = WARMUP_TIME)
+@Measurement(iterations = MEASUREMENT_ITERATIONS,
+        time = MEASUREMENT_TIME)
+@State(Scope.Benchmark)
+@Fork(value = 1, jvmArgs = { "-server", "-Xms128M", "-Xmx128M", "-Dcantaloupe.config=memory" })
 public class FilesystemCacheTest extends AbstractCacheTest {
 
     private Path fixturePath;
     private Path infoPath;
     private Path sourceImagePath;
     private Path derivativeImagePath;
     private FilesystemCache instance;
+
+    @Param({"10", "50", "100", "500", "1000", "5000"})
+    private int numThreads;
 
     @BeforeEach
+    @Setup
     public void setUp() throws Exception {
         super.setUp();
 
@@ -57,6 +84,7 @@ public void setUp() throws Exception {
     }
 
     @AfterEach
+    @TearDown
     public void tearDown() throws IOException {
         try {
             Files.walkFileTree(fixturePath, new DeletingFileVisitor());
@@ -374,7 +402,8 @@ void testGetSourceImageFileWithNonzeroTTL() throws Exception {
     }
 
     @Test
-    void testGetSourceImageFileConcurrently() throws Exception {
+    @Benchmark
+    public void testGetSourceImageFileConcurrently() throws Exception {
         assumeFalse(SystemUtils.IS_OS_WINDOWS); // TODO: this fails in Windows CI with a flurry of AccessDeniedExceptions
         final Identifier identifier = new Identifier("monkeys");
 
@@ -387,14 +416,24 @@ void testGetSourceImageFileConcurrently() throws Exception {
         }, () -> {
             instance.getSourceImageFile(identifier);
             return null;
-        }).run();
+        }, numThreads).run();
     }
 
     @Test
-    @Override
-    void testNewDerivativeImageInputStreamConcurrently() throws Exception {
+    @Benchmark
+    public void testNewDerivativeImageInputStreamConcurrently() throws Exception {
         assumeFalse(SystemUtils.IS_OS_WINDOWS); // TODO: this fails in Windows CI with a flurry of AccessDeniedExceptions
-        super.testNewDerivativeImageInputStreamConcurrently();
+        super.testNewDerivativeImageInputStreamConcurrently(numThreads);
+    }
+
+    @Benchmark
+    public void testPutWithInfoConcurrently() throws Exception {
+        super.testPutWithInfoConcurrently(numThreads);
+    }
+
+    @Benchmark
+    public void testPutWithStringConcurrently() throws Exception {
+        super.testPutWithStringConcurrently(numThreads);
     }
 
     /* newSourceImageOutputStream(Identifier) */