断断续续地不执行一项流口水规则

编程问答 2022-05-27

问题描述

我在文件中有一组流口水规则，预计会在 Java 对象的多个字段上触发。 一项特定规则不会在生产中随机触发。 我尝试通过模拟产品负载进行重现，但无法重现。

场景：
Default valube city = London

规则：
If Name = John
then set City = Sydney

问题：
Name = John
City = London //如果规则基于 drl 文件正确执行，则预期为悉尼

实施：
我正在使用 ExecuterService 和大小为 2 的 FixedThreadPool。
在传递给 ExecuterService call() 的 Callable 的 submit() 中， 我正在创建一个大小为 3 的 KieSession 的 ConcurrentLinkedQueue。 规则文件在这里传递给 KieSession 构造函数。

我的分析：
我认为这个问题与多线程和同步有关。 由于 KieSession 对象在线程之间共享，这会导致这样的问题吗？
或者我可能不知道 Drool 规则是否存在任何已知问题？
如果有人有任何线索，请告诉我。
提前致谢

解决方法

我会检查的东西。

  1. 与 execute(Runnable command) 不同，submit(Callable<T> task) 将捕获任何可抛出的对象并将其设置为内部字段。您一定不要忘记执行 Future#get() 以显示后台发生的任何异常，否则没有人会注意到中断您的 Callable 的错误。或者你可以使用 execute 并且异常会杀死线程并出现在系统错误日志中。

  2. 您提到了“随机行为”，我想到的唯一随机性是，drools 不会显示预测排序，然后以相同的显着性阻止规则的执行。是否可能是您在规则之间存在依赖关系并且一个规则创建了导致另一条规则无法启动的条件？而且由于流口水的随机性，然后阻塞执行，这种情况很少发生。

  3. 当然，您有责任使您的类线程安全，并使数据以线程安全的方式访问。默认情况下，fireAllRules() 将执行 then 块的同一线程。但是，如果您创建多个线程，则必须考虑 bean 和数据的线程安全性，（通常）而不是考虑 drools 本身。我看到默认城市是伦敦，它并不总是由（并行？）线程更新。你有它不稳定，不是吗？

  4. 写一个测试。你无法修复无法重现的东西。 load or stress testing 甚至可以重现间歇性问题。

droolsjavajavakiemultithreading