如何在storm框架中调用nexttuple和excute

2w3kk1z5  于 2021-06-24  发布在  Storm
关注(0)|答案(1)|浏览(342)

我认为每个任务都会包含一个spout或bolt的示例,并在一段时间内或为block调用它们,对吗?
如果是这样的话,由于每个任务都与工作进程中运行的某个线程相协调,并且有可能将同一个喷口或插销的两个或多个任务分配给同一个工作进程,在这种情况下,我们是否需要同步(特别是当喷口或插销包含关键资源(如静态成员)时)?为什么?

cbeh67ev

cbeh67ev1#

是的,同一个管道/螺栓的多个任务可以分配给同一个worker,并在同一个jvm中运行。我建议不要使用非线程安全的静态成员—在这种情况下,您不需要关心同步。

相关问题