创建一个 Esper 长时间运行的进程或服务答案

【问题标题】：Creating an Esper long running process or service创建一个 Esper 长时间运行的进程或服务
【发布时间】：2014-01-25 20:21:28
【问题描述】：

我想创建一个Esper 引擎长时间运行的进程，但我不确定 Esper 的线程模型，也不确定我应该实施的模型来执行此操作。我天真地尝试了以下方法：

public class EsperTest {

/**
 * @param args the command line arguments
 */
public static void main(String[] args) {
    //EPServiceProvider epService = EPServiceProviderManager.getDefaultProvider();
   EPServiceProvider epService = EPServiceProviderManager.getProvider("CoreEngine");
   epService.addServiceStateListener(new EPServiceStateListener() {

       @Override
       public void onEPServiceDestroyRequested(EPServiceProvider epsp) {
           System.out.println("Service destroyed");
       }

       @Override
       public void onEPServiceInitialized(EPServiceProvider epsp) {
           System.out.println("System initialised");
       }
   });

   epService.initialize();
}

}

但代码似乎执行到main() 方法的末尾，JVM 结束。

参考 Esper 文档，第 14.7 p456 节：

在默认配置中，每个引擎实例都维护一个定时器线程（内部定时器）在引擎内提供基于时间或计划的处理。默认分辨率内部定时器运行时间为 100 毫秒。内部定时器线程可以被禁用和应用程序可以改为将外部时间事件发送到引擎实例以执行计时器或按照应用程序要求的分辨率安排处理。

因此，我认为通过创建一个引擎实例（“CoreEngine”），至少会创建一个（定时器）线程，并假设这不是一个守护线程，main() 方法不会完成，但这似乎不是案例。

我是否必须在main() 中实现我自己的无限循环，或者是否有可以提供给 Esper 的配置来让它“永远”运行？

【问题讨论】：

标签： service daemon esper

【解决方案1】：

定时器线程是一个守护线程。使用这样的闩锁代替循环。

final CountDownLatch shutdownLatch = new CountDownLatch(1);
Runtime.getRuntime().addShutdownHook(new Thread() {
    public void run() {
        shutdownLatch.countDown();
    }
});
shutdownLatch.await();

【讨论】：