最近在storm框架下用esper处理一分钟内筛选后数据。在UpdateListener类内拿到数据(List集合),发现listener针对于同一个newEvents执行了5次。debug后发现listener有五个线程在跑,所以输出了五次。因为是刚接触esper,所以想问下,这块对于esper在多线程下如何控制listener对于update方法内对于同一个newEvents执行次数问题!十分感谢!
http://ju.outofmemory.cn/entry/55225