0

私は esper エンジンについては初めてで、複数のストリームの意味がわかりません。私はこのようなものを作成したい:

 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

4

1 に答える 1