[rules-users] RulesFlow - DroolsFlow - Parallelism - SplitNodes - Help
Kris Verlaenen
kris.verlaenen at cs.kuleuven.be
Mon Apr 12 11:03:41 EDT 2010
If you want to have concurrency (meaning the process will continue with other parts of the flow while it is waiting for some other node to continue), you will need to model this task you are waiting for as some external bit of work (using a work item node or a human task node if you're waiting for a human user) and use asynchronous execution of your work.
This means that the work item handler should not be executing synchronously (as that will make the engine wait for it) but rather start execution (in a separate thread or by invoking a service asynchronously) and return. Whenever the task is then completed, the engine should be notified again (same as before, using manager.completeWorkItem(..)).
Internally, the engine will not use multi-threading as execution is (near) instantaneous. Everything that cannot be executed immediately should be modeled using special nodes like work item node, wait state, sub process node, etc.
Kris
----- Original Message -----
From: Pedro Maria Buitrago Mantilla
To: Rules Users List
Cc: rules-users-request at lists.jboss.org
Sent: Friday, April 09, 2010 9:59 PM
Subject: Re: [rules-users] RulesFlow - DroolsFlow - Parallelism - SplitNodes - Help
Thanks for you answer,
I thought the performance model took the two branches and processed in parallel in java. Now, given that it is not, I would like to know that I can do in java to execute in parallel my two subflows.
The launcher is:
package com.epmbog.esb.drools.mediator;
import java.util.HashMap;
import java.util.Map;
import org.drools.KnowledgeBase;
import org.drools.KnowledgeBaseConfiguration;
import org.drools.KnowledgeBaseFactory;
import org.drools.builder.KnowledgeBuilder;
import org.drools.builder.KnowledgeBuilderFactory;
import org.drools.builder.ResourceType;
import org.drools.conf.MultithreadEvaluationOption;
import org.drools.io.ResourceFactory;
import org.drools.runtime.StatefulKnowledgeSession;
import com.epmbog.drools.utils.Constantes;
import com.epmbog.esb.drools.workitems.EJBGenericWorkItemHandler;
public class TestProcess {
public static final void main(String[] args) {
try {
KnowledgeBase knowledgeBase = readRule();
StatefulKnowledgeSession ksession = knowledgeBase.newStatefulKnowledgeSession();
ksession.getWorkItemManager().registerWorkItemHandler("TelnetConnection", new EJBGenericWorkItemHandler());
ksession.getWorkItemManager().registerWorkItemHandler( "TelnetDisonnection", new EJBGenericWorkItemHandler());
ksession.getWorkItemManager().registerWorkItemHandler( "TelnetSendCommands", new EJBGenericWorkItemHandler());
HashMap<String, Object> paramMap = new HashMap<String, Object>();
paramMap.put( Constantes.SOFT_SWITCH_IP , "10.134.2.2");
paramMap.put( Constantes.SOFT_SWITCH_USER , null);
paramMap.put( Constantes.SOFT_SWITCH_PASS , null);
paramMap.put( Constantes.SOFT_SWITCH_PORT , "6000");
paramMap.put( Constantes.UMG_IP , "10.134.2.11");
paramMap.put( Constantes.UMG_USER , "gestor");
paramMap.put( Constantes.UMG_PASS , "gestor");
paramMap.put( Constantes.UMG_PORT , "23");
Map<String, Object> parameters = new HashMap<String, Object>();
Map<String, Object> results = new HashMap<String, Object>();
Map<String, Object> mapaFormadoPorEsbSegunDatosInfraestructuraSolicitados = new HashMap<String, Object>();
mapaFormadoPorEsbSegunDatosInfraestructuraSolicitados.put("softswitch_user", "mediator");
mapaFormadoPorEsbSegunDatosInfraestructuraSolicitados.put("softswitch_pass", "mediator");
mapaFormadoPorEsbSegunDatosInfraestructuraSolicitados.put("softswitch_number", "6057000");
mapaFormadoPorEsbSegunDatosInfraestructuraSolicitados.put("softswitch_circuitInit", "864");
mapaFormadoPorEsbSegunDatosInfraestructuraSolicitados.put("softswitch_circuitEnd", "895");
mapaFormadoPorEsbSegunDatosInfraestructuraSolicitados.put("umg_port", "00");
mapaFormadoPorEsbSegunDatosInfraestructuraSolicitados.put("umg_slot", "03");
mapaFormadoPorEsbSegunDatosInfraestructuraSolicitados.put("umg_frame", "1");
mapaFormadoPorEsbSegunDatosInfraestructuraSolicitados.put("umg_cardType", "CUALQUIERJODA");
paramMap.put( Constantes.FM_PARAMETERS_MAP , mapaFormadoPorEsbSegunDatosInfraestructuraSolicitados);
parameters.put("factsMap", paramMap);
parameters.put("resultsMap", results);
ksession.startProcess( "com.epmbog.esb.drools.mediator.PriDigitalTest", parameters );
ksession.fireAllRules();
System.out.println("Cualquier cosa");
} catch ( Throwable t ) {
t.printStackTrace();
}
}
private static KnowledgeBase readRule() throws Exception {
KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();
kbuilder.add( ResourceFactory.newClassPathResource( "/com/epmbog/esb/drools/mediator/PriDigitalTest.rf", TestProcess.class ),
ResourceType.DRF );
kbuilder.add( ResourceFactory.newClassPathResource( "/com/epmbog/esb/drools/mediator/SoftSwitchFlow.rf", TestProcess.class ),
ResourceType.DRF );
kbuilder.add( ResourceFactory.newClassPathResource( "/com/epmbog/esb/drools/mediator/UMGFlow.rf", TestProcess.class ),
ResourceType.DRF );
KnowledgeBaseConfiguration configuration = KnowledgeBaseFactory
.newKnowledgeBaseConfiguration();
configuration.setOption( MultithreadEvaluationOption.YES );
KnowledgeBase kbase = KnowledgeBaseFactory.newKnowledgeBase(configuration);
kbase.addKnowledgePackages( kbuilder.getKnowledgePackages() );
return kbase;
}
}
Thank you,
PEDRO MARIA BUITRAGO MANTILLA
Bogotá, Colombia
2010/4/9 Mauricio Salatino <salaboy at gmail.com>
When we define two parallel branches in a business process we represent a real situation where two task needs to be completed in parallel. We are not expressing something low level as Concurrent (multi threaded) programming.
Does this explanation answer your question?
2010/4/9 Pedro Maria Buitrago Mantilla <pmbtgun at gmail.com>
Greetings for all,
We're learning about jboss rules ( drools ), in particular, drools flow by the workflow topic.
In the documentation, the parallelism is solved by means of split node of type 1 (AND).
However, when we execute the testing ,the execution is sequential.
In particular, the idea is that our workflow executes two subflows in parallel. For this target we configured a
"split node" with type 'AND' and a "join node" with type 'AND', no more configuration, Is it required another configurations?
Is it problem of standalone applications? We don't know.
This is the case:
0. Drools:
Created-By: Apache Maven
Built-By: trikkola
Build-Jdk: 1.5.0_15
Specification-Title: Drools :: API
Specification-Version: 5.0.1
Specification-Vendor: JBoss Inc.
Implementation-Title: Drools :: API
Implementation-Version: 5.0.1
Implementation-Vendor-Id: org.drools
Implementation-Vendor: JBoss Inc.
1. ProcessXML:
<?xml version="1.0" encoding="UTF-8"?>
<process xmlns="http://drools.org/drools-5.0/process"
xmlns:xs="http://www.w3.org/2001/XMLSchema-instance"
xs:schemaLocation="http://drools.org/drools-5.0/process drools-processes-5.0.xsd"
type="RuleFlow" name="PriDigitalTest" id="com.epmbog.esb.drools.mediator.PriDigitalTest" package-name="com.epmbog.esb.drools.mediator" >
<header>
<variables>
<variable name="factsMap" >
<type name="org.drools.process.core.datatype.impl.type.ObjectDataType" className="java.util.HashMap" />
</variable>
<variable name="resultsMap" >
<type name="org.drools.process.core.datatype.impl.type.ObjectDataType" className="java.util.HashMap" />
</variable>
</variables>
</header>
<nodes>
<start id="1" name="Start" x="126" y="16" width="48" height="48" />
<split id="19" name="AND" x="109" y="95" width="80" height="40" type="1" />
<subProcess id="17" name="UMGSubFlow" x="16" y="168" width="119" height="49" processId="com.epmbog.esb.drools.mediator.UMGFlow" waitForCompletion="false" independent="false" >
<mapping type="in" from="resultsMap" to="resultsMap" />
<mapping type="in" from="factsMap" to="factsMap" />
</subProcess>
<subProcess id="18" name="SoftSwitchSubFlow" x="167" y="168" width="119" height="49" processId="com.epmbog.esb.drools.mediator.SoftSwitchFlow" waitForCompletion="false" independent="false" >
<mapping type="in" from="resultsMap" to="resultsMap" />
<mapping type="in" from="factsMap" to="factsMap" />
</subProcess>
<join id="20" name="Join(And)" x="110" y="251" width="80" height="40" type="1" />
<end id="6" name="End" x="112" y="414" width="80" height="40" />
</nodes>
<connections>
<connection from="1" to="19" />
<connection from="19" to="17" />
<connection from="19" to="18" />
<connection from="17" to="20" />
<connection from="18" to="20" />
<connection from="20" to="6" />
</connections>
</process>
2. Chart
We greatly appreciate your help, any suggestions? Thank you a lot
PEDRO MARIA BUITRAGO MANTILLA
Bogotá, Colombia
_______________________________________________
rules-users mailing list
rules-users at lists.jboss.org
https://lists.jboss.org/mailman/listinfo/rules-users
--
- http://salaboy.wordpress.com
- http://www.jbug.com.ar
- Salatino "Salaboy" Mauricio -
_______________________________________________
rules-users mailing list
rules-users at lists.jboss.org
https://lists.jboss.org/mailman/listinfo/rules-users
------------------------------------------------------------------------------
_______________________________________________
rules-users mailing list
rules-users at lists.jboss.org
https://lists.jboss.org/mailman/listinfo/rules-users
Disclaimer: http://www.kuleuven.be/cwis/email_disclaimer.htm
-------------- next part --------------
An HTML attachment was scrubbed...
URL: http://lists.jboss.org/pipermail/rules-users/attachments/20100412/d59f3edf/attachment.html
-------------- next part --------------
A non-text attachment was scrubbed...
Name: not available
Type: image/jpeg
Size: 17132 bytes
Desc: not available
Url : http://lists.jboss.org/pipermail/rules-users/attachments/20100412/d59f3edf/attachment.jpe
More information about the rules-users
mailing list