nextTuple()을 초당 특정 횟수로 호출하려면 어떻게해야합니까?

Question

스파우트의 nextTuple 메소드를 초당 특정 횟수로 호출 할 수있는 방법이 있습니까?

Answer 1

이 작업을 수행 할 수 있지만 현재 분에서 nextTuple()이 얼마나 불려 졌는지 계산하고 원하는 터플 개수가 나온 경우 튜플을 방출하지 않고 return 만 호출합니다. 매회 nextTuple()을 처음으로 호출하면 카운터가 0으로 재설정됩니다. 이 같은

뭔가 :

private int counter = 0; 
private int currentMinute = 0; 
private final int tuplesPerMinute = 5; 

public void nextTuple() { 
    if(counter == tuplesPerMinute) { 
     int newMinute = TimeUnit.MILLISECONDS.toMinutes(System.currentTimeMillis()); 
     if(newMinute <= currentMinute) { 
      return; 
     } 

     counter = 0; 
     currentMinute = newMinute; 
    } 

    ++counter; 
    collector.emit(...); 
}