甩锅声明：本人英语一般，翻译只是为了做个笔记，所以有翻译错误的地方，错就错了，如果你想给我纠正，就给我留言，我会改过来，如果懒得理我，就直接划过即可。
drools的规则执行模式和线程安全
Drools支持下面的规则执行模式，这些模式决定了Drools如何以及何时执行规则：
- 被动模式：（默认）当用户或者应用明确调用了fireAllRules方法时，Drools会评估规则。Drools的被动模式对于需要直接控制规则评估和执行的应用程序，或者对于使用伪时钟实现的复杂的事件处理（CEP）应用程序来说都是是最好的。
被动模式的CEP应用程序代码示例
KieSessionConfiguration config = KieServices.Factory.get().newKieSessionConfiguration();
config.setOption( ClockTypeOption.get("pseudo") );
KieSession session = kbase.newKieSession( conf, null );
SessionPseudoClock clock = session.getSessionClock();
session.insert( tick1 );
session.fireAllRules();
clock.advanceTime(1, TimeUnit.SECONDS);
session.insert( tick2 );
session.fireAllRules();
clock.advanceTime(1, TimeUnit.SECONDS);
session.insert( tick3 );
session.fireAllRules();
session.dispose();
- 主动模式：如果用户或者应用程序调用fireUntilHalt方法，Drools会启动主动模式并持续的评估规则，直到用户或者应用程序调用halt方法。主动模式对于将规则的评估和执行委托给Drools的应用程序，或者使用实时时钟实现的CEP程序来说是最好的。主动模式对于使用主动查询的CEP应用程序是可选的。
主动模式的示例CEP应用代码
KieSessionConfiguration config = KieServices.Factory.get().newKieSessionConfiguration();
config.setOption( ClockTypeOption.get("realtime") );
KieSession session = kbase.newKieSession( conf, null );
new Thread( new Runnable() {
@Overridepublic void run() {
session.fireUntilHalt();
}
} ).start();
session.insert( tick1 );
... Thread.sleep( 1000L ); ...
session.insert( tick2 );
... Thread.sleep( 1000L ); ...
session.insert( tick3 );
session.halt();
session.dispose();
这个例子启用了一个专门的线程调用fireUntilHalt方法，启用专门的线程是为了防止drools在评估规则时当前线程无休止的被阻塞。这个专门的线程也可以在之后的阶段调用halt方法。
尽管你应该避免同时调用fireAllRules方法和fireUntilHalt方法，尤其是来自不同线程的调用，但是Drools是可以处理这种情况的，处理方法就是使用安全线程逻辑和一个内部的状态机。如果fireAllRules方法正在调用的同时，你又调用fireUntilHalt方法，drools会使用被动模式继续运行，直到fireAllRules方法操作完成，然后启用主动模式用来响应fireUntilHalt的调用。但是，如果drools是以主动模式下调用fireUntilHalt，同时你调用了fireAllRules方法，这个fireAllRules方法调用会被忽略，drools会继续以主动模式运行，直到你调用了halt方法。
为了在主动模式下添加线程安全，drools支持submit方法，你可以使用submit方法对线程安全中的kie会话进行分组和操作，原子操作：
在主动模式下使用submit方法执行原子操作的应用代码示例
KieSession session = ...;
new Thread( new Runnable() {
@Overridepublic void run() {
session.fireUntilHalt();
}
} ).start();
final FactHandle fh = session.insert( fact_a );
... Thread.sleep( 1000L ); ...
session.submit( new KieSession.AtomicAction() {
@Overridepublic void execute( KieSession kieSession ) {
fact_a.setField("value");
kieSession.update( fh, fact_a );
kieSession.insert( fact_1 );
kieSession.insert( fact_2 );
kieSession.insert( fact_3 );
}
} );
... Thread.sleep( 1000L ); ...
session.insert( fact_z );
session.halt();
session.dispose();
从客户端视角来看，线程安全和原子操作也是有帮助的。例如，你可能需要在给定时间内插入不止一条事实，但是需要drools去考虑将插入作为原子操作，并且等到所有插入完成之后，再次评估规则。