Merge pull request #9 from ponder-lab/fibers_additional_jmh_workload

Change workload (fibers)

Author: bgprudhomme

core/sail/memory/src/test/java/org/eclipse/rdf4j/sail/memory/benchmark/ConcurrentQueryBenchmark.java

@@ -88,7 +88,7 @@ public void tearDown() throws Exception {
 	public void hasStatement(Blackhole blackhole) throws Exception {
 		threads(numThreads, () -> {
 			try (SailRepositoryConnection connection = repository.getConnection()) {
-				for (int i = 0; i < 100; i++) {
+				for (int i = 0; i < 50; i++) {
 					boolean b = connection.hasStatement(null, null, null, true);
 					blackhole.consume(b);
 				}
@@ -100,7 +100,7 @@ public void hasStatement(Blackhole blackhole) throws Exception {
 	public void hasStatementSharedConnection(Blackhole blackhole) throws Exception {
 		try (SailRepositoryConnection connection = repository.getConnection()) {
 			threads(numThreads, () -> {
-				for (int i = 0; i < 100; i++) {
+				for (int i = 0; i < 50; i++) {
 					boolean b = connection.hasStatement(null, null, null, true);
 					blackhole.consume(b);
 				}
@@ -112,7 +112,7 @@ public void hasStatementSharedConnection(Blackhole blackhole) throws Exception {
 	public void getNamespaces(Blackhole blackhole) throws Exception {
 		threads(numThreads, () -> {
 			try (SailRepositoryConnection connection = repository.getConnection()) {
-				for (int i = 0; i < 100; i++) {
+				for (int i = 0; i < 50; i++) {
 					blackhole.consume(connection.getNamespaces().stream().count());
 				}
 			}
@@ -123,7 +123,7 @@ public void getNamespaces(Blackhole blackhole) throws Exception {
 	public void getNamespacesSharedConnection(Blackhole blackhole) throws Exception {
 		try (SailRepositoryConnection connection = repository.getConnection()) {
 			threads(numThreads, () -> {
-				for (int i = 0; i < 100; i++) {
+				for (int i = 0; i < 50; i++) {
 					blackhole.consume(connection.getNamespaces().stream().count());
 				}
 			});

core/sail/memory/src/test/java/org/eclipse/rdf4j/sail/memory/benchmark/MemValueFactoryConcurrentBenchmark.java

@@ -66,7 +66,7 @@ public class MemValueFactoryConcurrentBenchmark extends BaseConcurrentBenchmark
 	@Param({ "10", "50", "100", "500", "1000", "5000" })
 	public int numThreads;
 
-	public static final int BUCKET_SIZE = 10000;
+	public static final int BUCKET_SIZE = 5000;
 	private SailRepository repository;
 	private List<List<Value>> values;