我使用的是storm架构,我有一个bolt可以生成5个线程(/tasks,据我所知,它们是一个可以互换的术语)。有没有办法设置一个所有线程都可以读写的变量?谢谢:)。
oyjwcjzk1#
为了理解storm中的并行性(以及任务、执行者、工作者的含义),我建议:理解storm拓扑的并行性。在您的bolt中,您可以拥有一个共享资源(比如bolt的示例变量),但是您需要同步访问它,否则您将陷入深深的麻烦(不出所料)。但是共享的资源不会在不同的螺栓之间共享。
1条答案
按热度按时间oyjwcjzk1#
为了理解storm中的并行性(以及任务、执行者、工作者的含义),我建议:理解storm拓扑的并行性。
在您的bolt中,您可以拥有一个共享资源(比如bolt的示例变量),但是您需要同步访问它,否则您将陷入深深的麻烦(不出所料)。但是共享的资源不会在不同的螺栓之间共享。