This is an automated email from the ASF dual-hosted git repository.
mariofusco pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-kie-benchmarks.git
The following commit(s) were added to refs/heads/main by this push:
new 25381b90 [DROOLS-7576] Add benchmarks for secondary super cache issue
(#270)
25381b90 is described below
commit 25381b903a4f81799a50f664288bfafeadeb928d
Author: Toshiya Kobayashi <[email protected]>
AuthorDate: Tue Oct 24 22:58:06 2023 +0900
[DROOLS-7576] Add benchmarks for secondary super cache issue (#270)
* [DROOLS-7576] Add benchmarks for secondary super cache issue
- ConcurrentUpdateRightTupleBenchmark calls RightTupleImpl.getTupleSink() a
lot
- ConcurrentUpdateLeftTupleBenchmark calls LeftTuple.getTupleSink() a lot
* - add comment
---
.../java/org/drools/benchmarks/common/model/A.java | 10 ++
.../java/org/drools/benchmarks/common/model/B.java | 10 ++
.../common/providers/RulesWithJoinsProvider.java | 15 ++-
.../ConcurrentUpdateLeftTupleBenchmark.java | 142 +++++++++++++++++++++
.../ConcurrentUpdateRightTupleBenchmark.java | 142 +++++++++++++++++++++
5 files changed, 318 insertions(+), 1 deletion(-)
diff --git
a/drools-benchmarks-parent/drools-benchmarks-common/src/main/java/org/drools/benchmarks/common/model/A.java
b/drools-benchmarks-parent/drools-benchmarks-common/src/main/java/org/drools/benchmarks/common/model/A.java
index 9b770740..f05587c5 100644
---
a/drools-benchmarks-parent/drools-benchmarks-common/src/main/java/org/drools/benchmarks/common/model/A.java
+++
b/drools-benchmarks-parent/drools-benchmarks-common/src/main/java/org/drools/benchmarks/common/model/A.java
@@ -29,4 +29,14 @@ public class A extends AbstractBean {
public A(final long id, final int value) {
super(id, value);
}
+
+ private int value2;
+
+ public int getValue2() {
+ return value2;
+ }
+
+ public void setValue2(int value2) {
+ this.value2 = value2;
+ }
}
diff --git
a/drools-benchmarks-parent/drools-benchmarks-common/src/main/java/org/drools/benchmarks/common/model/B.java
b/drools-benchmarks-parent/drools-benchmarks-common/src/main/java/org/drools/benchmarks/common/model/B.java
index 8502e69c..116a14ad 100644
---
a/drools-benchmarks-parent/drools-benchmarks-common/src/main/java/org/drools/benchmarks/common/model/B.java
+++
b/drools-benchmarks-parent/drools-benchmarks-common/src/main/java/org/drools/benchmarks/common/model/B.java
@@ -29,4 +29,14 @@ public class B extends AbstractBean {
public B(final long id, final int value) {
super(id, value);
}
+
+ private int value2;
+
+ public int getValue2() {
+ return value2;
+ }
+
+ public void setValue2(int value2) {
+ this.value2 = value2;
+ }
}
diff --git
a/drools-benchmarks-parent/drools-benchmarks-common/src/main/java/org/drools/benchmarks/common/providers/RulesWithJoinsProvider.java
b/drools-benchmarks-parent/drools-benchmarks-common/src/main/java/org/drools/benchmarks/common/providers/RulesWithJoinsProvider.java
index 134e71b0..db664daf 100644
---
a/drools-benchmarks-parent/drools-benchmarks-common/src/main/java/org/drools/benchmarks/common/providers/RulesWithJoinsProvider.java
+++
b/drools-benchmarks-parent/drools-benchmarks-common/src/main/java/org/drools/benchmarks/common/providers/RulesWithJoinsProvider.java
@@ -36,6 +36,8 @@ public class RulesWithJoinsProvider implements DRLProvider {
private String rootConstraintValueOperator = ">";
private String joinConstraintValueOperator = ">";
+ private boolean withNot = false;
+
public RulesWithJoinsProvider() { }
public RulesWithJoinsProvider(final int numberOfJoins, final boolean
withCep, final boolean withImports ) {
@@ -96,6 +98,11 @@ public class RulesWithJoinsProvider implements DRLProvider {
return this;
}
+ public RulesWithJoinsProvider withNot(boolean withNot) {
+ this.withNot = withNot;
+ return this;
+ }
+
public RulesWithJoinsProvider withPrioritizedBySalience(boolean
prioritizedBySalience) {
this.prioritizedBySalience = prioritizedBySalience;
return this;
@@ -170,7 +177,13 @@ public class RulesWithJoinsProvider implements DRLProvider
{
}
private String getJoinConstraints(int index) {
- return " $" + (char)('b'+index) + " : " + (char)('B'+index) + "(
value " + joinConstraintValueOperator + " $" + (char)('a'+index) + ".value )\n";
+ String pattern = " $" + (char)('b'+index) + " : " + (char)('B'+index)
+ "( value " + joinConstraintValueOperator + " $" + (char)('a'+index) + ".value
)\n";
+ if (withNot) {
+ String notPattern = " not " + (char)('B'+index) + "( value < $" +
(char)('a'+index) + ".value )\n";
+ return notPattern + pattern;
+ } else {
+ return pattern;
+ }
}
private String generateConsequence() {
diff --git
a/drools-benchmarks-parent/drools-benchmarks/src/main/java/org/drools/benchmarks/concurrent/ConcurrentUpdateLeftTupleBenchmark.java
b/drools-benchmarks-parent/drools-benchmarks/src/main/java/org/drools/benchmarks/concurrent/ConcurrentUpdateLeftTupleBenchmark.java
new file mode 100644
index 00000000..a8445008
--- /dev/null
+++
b/drools-benchmarks-parent/drools-benchmarks/src/main/java/org/drools/benchmarks/concurrent/ConcurrentUpdateLeftTupleBenchmark.java
@@ -0,0 +1,142 @@
+/*
+ * Copyright 2023 Red Hat, Inc. and/or its affiliates.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.drools.benchmarks.concurrent;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.TimeUnit;
+
+import org.drools.benchmarks.common.AbstractBenchmark;
+import org.drools.benchmarks.common.model.A;
+import org.drools.benchmarks.common.model.B;
+import org.drools.benchmarks.common.model.C;
+import org.drools.benchmarks.common.model.D;
+import org.drools.benchmarks.common.providers.RulesWithJoinsProvider;
+import org.drools.benchmarks.common.util.BuildtimeUtil;
+import org.drools.benchmarks.common.util.RuntimeUtil;
+import org.drools.kiesession.session.StatefulKnowledgeSessionImpl;
+import org.kie.api.conf.EventProcessingOption;
+import org.kie.api.runtime.KieSession;
+import org.kie.internal.conf.ParallelExecutionOption;
+import org.openjdk.jmh.annotations.Benchmark;
+import org.openjdk.jmh.annotations.Level;
+import org.openjdk.jmh.annotations.Measurement;
+import org.openjdk.jmh.annotations.Param;
+import org.openjdk.jmh.annotations.Setup;
+import org.openjdk.jmh.annotations.TearDown;
+import org.openjdk.jmh.annotations.Warmup;
+
+@Warmup(iterations = 20)
+@Measurement(iterations = 20)
+public class ConcurrentUpdateLeftTupleBenchmark extends AbstractBenchmark {
+
+ @Param({"32"})
+ private int rulesNr;
+
+ @Param({"15"})
+ private int factsNr;
+
+ @Param({"3"})
+ private int joinsNr;
+
+ private static final int SESSIONS_NR = 20;
+
+ private List<KieSession> kieSessions = new ArrayList<>(); // Do not use
kieSession in AbstractBenchmark
+
+ @Setup
+ public void setupKieBase() {
+ final RulesWithJoinsProvider drlProvider = new
RulesWithJoinsProvider(joinsNr, false, true)
+ .withNot(true)
+ .withGeneratedConsequence(false)
+ .withConsequence(" $a.setValue2($a.getValue2() + 1);\n" +
+ " update($a);\n"); // this update
triggers LeftInputAdapterNode.modifyObject -> LeftTuple.getTupleSink
+ //System.out.println(drlProvider.getDrl(rulesNr));
+ kieBase =
BuildtimeUtil.createKieBaseFromDrl(drlProvider.getDrl(rulesNr),
+
ParallelExecutionOption.SEQUENTIAL,
+
EventProcessingOption.CLOUD);
+ //ReteDumper.dumpRete(kieBase);
+ }
+
+ @Setup(Level.Iteration)
+ @Override
+ public void setup() {
+ for (int n = 0; n < SESSIONS_NR; n++) {
+ StatefulKnowledgeSessionImpl session =
(StatefulKnowledgeSessionImpl) RuntimeUtil.createKieSession(kieBase);
+ A a = new A(rulesNr + 1);
+
+ session.insert(a);
+
+ for (int i = 0; i < factsNr; i++) {
+
+ session.insert(new B(rulesNr + i + 3));
+ if (joinsNr > 1) {
+ session.insert(new C(rulesNr + factsNr + i + 3));
+ }
+ if (joinsNr > 2) {
+ session.insert(new D(rulesNr + factsNr * 2 + i + 3));
+ }
+ }
+ kieSessions.add(session);
+ }
+ }
+
+ @TearDown(Level.Iteration)
+ public void tearDoneIter() {
+ for (int n = 0; n < SESSIONS_NR; n++) {
+ kieSessions.get(n).dispose();
+ }
+ kieSessions.clear();
+ }
+
+ @Benchmark
+ public int test() {
+ ExecutorService executor = Executors.newFixedThreadPool(SESSIONS_NR);
+
+ for (int n = 0; n < SESSIONS_NR; n++) {
+ final int index = n;
+ executor.execute(new Runnable() {
+
+ public void run() {
+ int fired = kieSessions.get(index).fireAllRules();
+// System.out.println(fired);
+ }
+ });
+ }
+
+ executor.shutdown();
+ try {
+ executor.awaitTermination(300, TimeUnit.SECONDS);
+ } catch (InterruptedException e) {
+ throw new RuntimeException(e);
+ }
+ return kieSessions.size();
+ }
+
+ public static void main(String[] args) {
+ ConcurrentUpdateLeftTupleBenchmark benchmark = new
ConcurrentUpdateLeftTupleBenchmark();
+
+ benchmark.rulesNr = 32;
+ benchmark.factsNr = 15;
+ benchmark.joinsNr = 3;
+
+ benchmark.setupKieBase();
+ benchmark.setup();
+ benchmark.test();
+ }
+}
\ No newline at end of file
diff --git
a/drools-benchmarks-parent/drools-benchmarks/src/main/java/org/drools/benchmarks/concurrent/ConcurrentUpdateRightTupleBenchmark.java
b/drools-benchmarks-parent/drools-benchmarks/src/main/java/org/drools/benchmarks/concurrent/ConcurrentUpdateRightTupleBenchmark.java
new file mode 100644
index 00000000..f2c400e0
--- /dev/null
+++
b/drools-benchmarks-parent/drools-benchmarks/src/main/java/org/drools/benchmarks/concurrent/ConcurrentUpdateRightTupleBenchmark.java
@@ -0,0 +1,142 @@
+/*
+ * Copyright 2023 Red Hat, Inc. and/or its affiliates.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.drools.benchmarks.concurrent;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.TimeUnit;
+
+import org.drools.benchmarks.common.AbstractBenchmark;
+import org.drools.benchmarks.common.model.A;
+import org.drools.benchmarks.common.model.B;
+import org.drools.benchmarks.common.model.C;
+import org.drools.benchmarks.common.model.D;
+import org.drools.benchmarks.common.providers.RulesWithJoinsProvider;
+import org.drools.benchmarks.common.util.BuildtimeUtil;
+import org.drools.benchmarks.common.util.RuntimeUtil;
+import org.drools.kiesession.session.StatefulKnowledgeSessionImpl;
+import org.kie.api.conf.EventProcessingOption;
+import org.kie.api.runtime.KieSession;
+import org.kie.internal.conf.ParallelExecutionOption;
+import org.openjdk.jmh.annotations.Benchmark;
+import org.openjdk.jmh.annotations.Level;
+import org.openjdk.jmh.annotations.Measurement;
+import org.openjdk.jmh.annotations.Param;
+import org.openjdk.jmh.annotations.Setup;
+import org.openjdk.jmh.annotations.TearDown;
+import org.openjdk.jmh.annotations.Warmup;
+
+@Warmup(iterations = 20)
+@Measurement(iterations = 20)
+public class ConcurrentUpdateRightTupleBenchmark extends AbstractBenchmark {
+
+ @Param({"32"})
+ private int rulesNr;
+
+ @Param({"15"})
+ private int factsNr;
+
+ @Param({"3"})
+ private int joinsNr;
+
+ private static final int SESSIONS_NR = 20;
+
+ private List<KieSession> kieSessions = new ArrayList<>(); // Do not use
kieSession in AbstractBenchmark
+
+ @Setup
+ public void setupKieBase() {
+ final RulesWithJoinsProvider drlProvider = new
RulesWithJoinsProvider(joinsNr, false, true)
+ .withNot(true)
+ .withGeneratedConsequence(false)
+ .withConsequence(" $b.setValue2($b.getValue2() + 1);\n" +
+ " update($b);\n"); // this update
triggers BetaNode.modifyObject -> RightTupleImpl.getTupleSink
+ //System.out.println(drlProvider.getDrl(rulesNr));
+ kieBase =
BuildtimeUtil.createKieBaseFromDrl(drlProvider.getDrl(rulesNr),
+
ParallelExecutionOption.SEQUENTIAL,
+
EventProcessingOption.CLOUD);
+ //ReteDumper.dumpRete(kieBase);
+ }
+
+ @Setup(Level.Iteration)
+ @Override
+ public void setup() {
+ for (int n = 0; n < SESSIONS_NR; n++) {
+ StatefulKnowledgeSessionImpl session =
(StatefulKnowledgeSessionImpl) RuntimeUtil.createKieSession(kieBase);
+ A a = new A(rulesNr + 1);
+
+ session.insert(a);
+
+ for (int i = 0; i < factsNr; i++) {
+
+ session.insert(new B(rulesNr + i + 3));
+ if (joinsNr > 1) {
+ session.insert(new C(rulesNr + factsNr + i + 3));
+ }
+ if (joinsNr > 2) {
+ session.insert(new D(rulesNr + factsNr * 2 + i + 3));
+ }
+ }
+ kieSessions.add(session);
+ }
+ }
+
+ @TearDown(Level.Iteration)
+ public void tearDoneIter() {
+ for (int n = 0; n < SESSIONS_NR; n++) {
+ kieSessions.get(n).dispose();
+ }
+ kieSessions.clear();
+ }
+
+ @Benchmark
+ public int test() {
+ ExecutorService executor = Executors.newFixedThreadPool(SESSIONS_NR);
+
+ for (int n = 0; n < SESSIONS_NR; n++) {
+ final int index = n;
+ executor.execute(new Runnable() {
+
+ public void run() {
+ int fired = kieSessions.get(index).fireAllRules();
+// System.out.println(fired);
+ }
+ });
+ }
+
+ executor.shutdown();
+ try {
+ executor.awaitTermination(300, TimeUnit.SECONDS);
+ } catch (InterruptedException e) {
+ throw new RuntimeException(e);
+ }
+ return kieSessions.size();
+ }
+
+ public static void main(String[] args) {
+ ConcurrentUpdateRightTupleBenchmark benchmark = new
ConcurrentUpdateRightTupleBenchmark();
+
+ benchmark.rulesNr = 32;
+ benchmark.factsNr = 15;
+ benchmark.joinsNr = 3;
+
+ benchmark.setupKieBase();
+ benchmark.setup();
+ benchmark.test();
+ }
+}
\ No newline at end of file
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
