[JBoss JIRA] Created: (JBRULES-1392) Rules behave incorrectly (randomly) in multi-threaded environment
by Brian Stiles (JIRA)
Rules behave incorrectly (randomly) in multi-threaded environment
-----------------------------------------------------------------
Key: JBRULES-1392
URL: http://jira.jboss.com/jira/browse/JBRULES-1392
Project: JBoss Drools
Issue Type: Bug
Security Level: Public (Everyone can see)
Affects Versions: 4.0.3
Reporter: Brian Stiles
Rules behave seemingly indeterminately when sessions are created from the same RuleBase and executed in multiple threads. The problem is a bit difficult to reproduce. The following code demonstrates the behavior in my environment (single processor PowerBook), but not on every try. I've had up to 5 consecutive executions not exhibit the problem before the failure was exhibited, so you may need to run the class a number of times to see the problem. Also, I periodically get OutOfMemoryErrors when using the default heap size (64m). I've had better success with -Xmx256m. That, by the way, is suspiciously coincidental to the random nature of the incorrect rule firing problem.
I've experienced this behavior in my application, and it manifests by rules firing from time to time that shouldn't have fired. I can't see a pattern to the rules that fire inappropriately, and there absolutely were not facts asserted that would support the firing of the rule.
Synchronizing the calls to insert, fireAllRules, and dispose on the session object seems to get rid of the problem, giving further evidence to the guess that it's a multithreading bug.
Please, please, please find a solution to this problem. This will be a serious scalability problem for my application. I'm more than happy to help however I can. I've stepped through Drools code before and found solutions, but I really don't know where to go with this one.
Following is the code (self-contained class with main method) that I've used to demonstrate the problem.
Thank you!
--
package sample;
import java.io.StringReader;
import java.util.ArrayList;
import org.drools.RuleBase;
import org.drools.RuleBaseConfiguration;
import org.drools.RuleBaseFactory;
import org.drools.StatefulSession;
import org.drools.compiler.PackageBuilder;
import org.drools.compiler.PackageBuilderConfiguration;
public class MultithreadedRuleBaseProblem {
public static void main(String[] args) throws Exception {
final PackageBuilderConfiguration packageBuilderConfiguration =
new PackageBuilderConfiguration();
final PackageBuilder packageBuilder = new PackageBuilder(packageBuilderConfiguration);
packageBuilder.addPackageFromDrl(new StringReader("\n"
+ "package sample\n"
+ "\n"
+ "import java.lang.Integer;\n"
+ "global java.util.ArrayList shouldFireList;\n"
+ "global java.util.ArrayList shouldNotFireList;\n"
+ "\n"
+ "rule should_fire\n"
+ " when\n"
+ " $e : Integer(intValue == -1)\n"
+ " $f : Integer(intValue > $e)\n"
+ " then \n"
+ " shouldFireList.add($f);\n"
+ "end \n"
+ "\n"
+ "rule should_not_fire\n"
+ " when\n"
+ " $f : String()\n"
+ " then \n"
+ " shouldNotFireList.add($f);\n"
+ "end \n"));
final RuleBaseConfiguration ruleBaseConfiguration = new RuleBaseConfiguration();
final RuleBase ruleBase = RuleBaseFactory.newRuleBase(ruleBaseConfiguration);
ruleBase.addPackage(packageBuilder.getPackage());
final Exception[] exception = {
null
};
final Thread t[] = new Thread[50];
for (int i = 0; i < t.length; i++) {
final int count = i;
t[i] = new Thread(new Runnable() {
public void run() {
try {
System.out.println("Start " + count);
final int iterations = count * 15 + 3000;
final ArrayList shouldFireList = new ArrayList();
final ArrayList shouldNotFireList = new ArrayList();
final StatefulSession session2 = ruleBase.newStatefulSession();
session2.setGlobal("shouldFireList", shouldFireList);
session2.setGlobal("shouldNotFireList", shouldNotFireList);
session2.insert(new Integer(- 1));
for (int k = 0; k < iterations; k++) {
session2.insert(new Integer(k));
}
session2.insert("foo");
System.out.println("Fire " + count);
session2.fireAllRules();
session2.dispose();
if (shouldFireList.size() != iterations) {
System.out.println("Thread "
+ count
+ " shouldFireList.size(): expected "
+ iterations
+ " was "
+ shouldFireList.size()
+ "\n!!!!! Thread "
+ count
+ " rule didn't fire as many times as it should have!!!!!!!!!!!!!!!!!!");
}
} catch (Exception e) {
e.printStackTrace();
exception[0] = e;
}
System.out.println("Thread " + count + " done");
}
});
t[i].start();
}
for (int i = 0; i < t.length; i++) {
t[i].join();
}
System.out.println("done");
}
}
--
This message is automatically generated by JIRA.
-
If you think it was sent incorrectly contact one of the administrators: http://jira.jboss.com/jira/secure/Administrators.jspa
-
For more information on JIRA, see: http://www.atlassian.com/software/jira
18 years, 5 months
[JBoss JIRA] Created: (JBCACHE-1126) distribution example cannot complete (2.0 CR3)
by Aleksandar Kostadinov (JIRA)
distribution example cannot complete (2.0 CR3)
----------------------------------------------
Key: JBCACHE-1126
URL: http://jira.jboss.com/jira/browse/JBCACHE-1126
Project: JBoss Cache
Issue Type: Bug
Security Level: Public (Everyone can see)
Affects Versions: 2.0.0.CR3
Environment: linux, jdk1.5.0_11
Reporter: Aleksandar Kostadinov
Assigned To: Manik Surtani
Fix For: 2.0.0.CR4
All examples fail - some can't compile, some at runtime. These that compile are running and seem to do something (at least eat some CPU cycles) but don't complete within few minutes and through exceptions so I consider them failing. Anything I'm doing wrong? btw I run with ant.
One problem with a known reason: on loadtime example path is specified with ";" between file names and not ":". To be portable to windows and unix ant path or location element has to be used.
--
This message is automatically generated by JIRA.
-
If you think it was sent incorrectly contact one of the administrators: http://jira.jboss.com/jira/secure/Administrators.jspa
-
For more information on JIRA, see: http://www.atlassian.com/software/jira
18 years, 5 months
[JBoss JIRA] Created: (JBRULES-1333) Enum doesn't work in the decision table
by tobato king (JIRA)
Enum doesn't work in the decision table
---------------------------------------
Key: JBRULES-1333
URL: http://jira.jboss.com/jira/browse/JBRULES-1333
Project: JBoss Drools
Issue Type: Bug
Security Level: Public (Everyone can see)
Components: Decision tables
Affects Versions: 4.0.3
Reporter: tobato king
I have a enum like this:
public enum JobStatus {
UNEMPLOYED,EMPLOYED,RETIRED
}
I know i have to get a rule like this:
rule "EMPLOYED test"
no-loop true
when
$moneys:List()
$person:Person(jobstatus == JobStatus.EMPLOYED)
then
System.out.println( "EMPLOYED"+$person.getName());
$moneys.add(new Money(2));
retract($person);
end
I have imported the enum class and tryed define condition like JobStatus.EMPLOYED, EMPLOYED,"EMPLOYED", but nothing work!
I found JobStatus.EMPLOYED was convert to
$person:Person(jobstatus == "JobStatus.EMPLOYED")
buy the SpreadsheetCompiler
So, I think it seems have a bug.
--
This message is automatically generated by JIRA.
-
If you think it was sent incorrectly contact one of the administrators: http://jira.jboss.com/jira/secure/Administrators.jspa
-
For more information on JIRA, see: http://www.atlassian.com/software/jira
18 years, 5 months