Несколько потоков в CEP Engine (Esper)

Question

Я новичок в esper engine, и я не уверен в значении нескольких потоков. Я хочу, чтобы создать что-то вроде этого: класс генератора

CepEnigine cep = new CepEngine(); 
Controller.getInstance().setRuntime(cep.getRuntime()); 

for(int i = 0; i < 5; i++) 
    new EventGenerator().start(); 

События определяется следующим образом:

public class EventGenerator extends Thread 
{ 
    @Override 
    public void run() 
    { 
     while (true) 
     { 
      MyEvent e = new Event(); 
      Controller.getInstance().sendToCEP(e); 
      Thread.sleep(500); 
     } 
    } 
} 

контроллера многопоточностью синглтона, который держит epruntime для отправки событий. В классе CepEngine у ​​меня также есть инструкция EPL для прослушивания событий. Это хорошее значение для нескольких потоков событий?

поток THX

Answer 1

Событие является «Время упорядоченная последовательность событий во времени»

Esper FAQs for Reference

В примере вы дали, есть один eventStream называется MyEvent

Пример нескольких потоков - Streams для Order and OrderBook. Из событий заказа мы можем отфильтровать заказ на книгу и создать поток событий портфеля заказов,

Проверьте этот тест в экстрасенс кодовой базе TestFilterPropertySimple