Drools KieSession在将对象插入到基于定时器的规则会话时导致内存泄漏

Question

我们想用Drools来做一个延迟工作。因此，我使用定时器(INT:5S)来实现这一点。但是，在我将一个事实对象插入到KieSession之后，KieSession将启动一个独立的“thread-xx”来处理这个延迟作业，但是这个线程将永远不会结束，尽管规则已经在5s之后执行。

是否有一些选项，使那些定时器线程关闭后执行？我知道drl文件中的drools.halt()，但是，它将停止整个会话，而不是这个kiesession中的每个线程。

下面是我的代码：

1.主体班

        KieServices ks = KieServices.Factory.get();
        final KieContainer kContainer = ks.getKieClasspathContainer();
        final KieSessionConfiguration ksconf = ks.newKieSessionConfiguration();
        ksconf.setOption(TimedRuleExectionOption.YES);
        final KieSession kSession = kContainer.newKieSession("ksession-rules", ksconf);

        for (int i = 0; i < 100000; i++) {
            Thread t1 = new Thread(new Runnable() {
                public void run() {
                    Message message = new Message();
                    message.setStatus(Message.HELLO);
                    kSession.insert(message);
                    kSession.fireUntilHalt();
                }
            });

            t1.start();
        }

    dialect "mvel"
    rule "Hello World"
    timer(int:10s)
       when
          m : Message(m.status == Message.HELLO)
       then
          System.out.println( "no hello"+m.message );
    end

Answer 1

我认为您不应该使用Drools来调度大量的TimerTasks。您可以将计时器设置为全局，并根据需要调用它的schedule方法。

很明显，简单的timer属性无法处理使用java.util.timer和TimerTask API可能出现的各种场景。它的主要目的是覆盖简单的场景，只要有一个条件存在，就可以重复执行一些东西。此外，定时器属性存在，所以Drools marketing可以声称“您可以在Drools中完成所有操作，不需要了解（太多）Java”。呸。