在apachestorm中,如何在不使用sleep命令的情况下限制喷口传输元组的秒数?例如,我不想使用此代码。谢谢
puplic Void Next Tuple(){ utils.sleep(time); }
vbopmzt11#
我假设你希望元组以较慢的速度发射?作为一个程序员,这是一个非常简单的解决方案,你应该已经想出了。伪代码是这样的:
class MyClass { private boolean timeUp = false; public void nextTuple() { if (timeUp) { EmitMyTuple(); ResetTimeCounterToZero(); timeUp = false; } else { boolean greater = CheckIfTimeIsGreaterThanOneSecond(); if (greater) {timeUp = true;} } } SleepForFewMilliseconds(); }
1条答案
按热度按时间vbopmzt11#
我假设你希望元组以较慢的速度发射?作为一个程序员,这是一个非常简单的解决方案,你应该已经想出了。伪代码是这样的: