I think that even with rulebase partitions, we should continue to support current execution mode. So, we should keep a rulebase configuration that basically allow the user to defines: either single-thread (as it is today) or multi-thread (as we are trying to achieve) execution.

    Having that in mind, in the multi-thread mode:

(A) What does "parallel evaluation of a rulebase" mean? Is it designed
to optimise, for example, two threads processing a stateless and
stateful session?
   Means that rules that do not share nodes, being independent of each other (from an evaluation perspective), will be evaluated in parallel. This is very common scenario and a desidered feature in CEP engines.

(B) Are there only two partitions, both of which are invisible to the
user? Is there any value in allowing user-defined partitions?
    There will be as many partitions as the compiler can create for the given set of rules. Rules that share more nodes, are more difficult to partition, while rules that are independent from an LHS point of view, are easier to parallelize. In my opinion, the only thing that may be helpful to expose and allow the user to control is the maximum size of the thread pool that is used to propagate facts. Even that I'm not sure is so helpful, because it is complex to fine tune such things, since the partitioning is completely dependent on the rules added to the rulebase.

(C) Does the partition used depend upon what type of session is used
(i.e. stateless always uses the partition without an agenda whereas
stateful always uses the partition with an agenda)?
    The partitioning of the rulebase is dependent upon the rules in the rulebase and nothing more. But that is different from the agenda. The agenda issue is much more complex, because even with partitions we can keep a single deterministic agenda (as long as it is not in active mode - runUntilHalt). Now, if the agenda is in active mode, or if we have multiple agendas (1 per partition, for instance), then the engine behavior becomes indeterministic. This is a common scenario in CEP systems that have multiple different "queries" running over the same set of streams, trying to detect and act upon them as soon as they are detected, and event streams are indeterministic by their own nature. In common rules engines scenarios, I'm not sure we can run in this indeterministic mode.

(D) Can a rule sometimes be deterministic and sometimes not (i.e.
depends upon the type of session)?
    It will always depend on the set of rules (the rulebase), not the type of session. One rule is always deterministic when considered in isolation, but two or more rules may or may not be deterministic in relation to each other. Just remember Eisten's Relativity Theory... ;)

   []s
   Edson




--
Edson Tirelli
JBoss Drools Core Development
JBoss, a division of Red Hat <at> www.jboss.com

Hello,

I have and less loop (the rule should only executed one for one InputObject) in the follwing rule although I use "no-loop":

rule "rulename"
  dialect "java"
  no-loop   
    when
        io: InputObject (type == InputObject.Type.Typename)
    then
        io.setStringPropertyValue(InputObject.PROPERTYVALUE, "somestring");
        update(oo);
       
end

I've read that I have to overwrite hashcode and equals, can this be the reason? If yes, do you have an example how to overwrite these methods?

Thomas

Hi, I used no-loop true but it still loops!!

Thomas

Hi

you must use "no-loop true" and the rule will be executed one for one InputObject.


2008/8/1 thomas kukofka <thomaskukofka at web.de>:

> Hello,

> 

> I have and less loop (the rule should only executed one for one InputObject)

> in the follwing rule although I use "no-loop":

> 

> rule "rulename"

>   dialect "java"

>   no-loop

>     when

>         io: InputObject (type == InputObject.Type.Typename)

>     then

>         io.setStringPropertyValue(InputObject.PROPERTYVALUE, "somestring");

>         update(oo);

> 

> end

> 

> I've read that I have to overwrite hashcode and equals, can this be the

> reason? If yes, do you have an example how to overwrite these methods?

> 

> Thomas

Hi, I used no-loop true but it still loops!!

Thomas

Hi

you must use "no-loop true" and the rule will be executed one for one InputObject.


2008/8/1 thomas kukofka <thomaskukofka at web.de>:

> Hello,

> 

> I have and less loop (the rule should only executed one for one InputObject)

> in the follwing rule although I use "no-loop":

> 

> rule "rulename"

>   dialect "java"

>   no-loop

>     when

>         io: InputObject (type == InputObject.Type.Typename)

>     then

>         io.setStringPropertyValue(InputObject.PROPERTYVALUE, "somestring");

>         update(oo);

> 

> end

> 

> I've read that I have to overwrite hashcode and equals, can this be the

> reason? If yes, do you have an example how to overwrite these methods?

> 

> Thomas