Дросселируйте количество вызовов метода

Question

В моем коде я отправляю пакетные запросы в пользовательскую базу данных. Время отклика каждой партии равно миллисекундам.

Однако у меня есть ограничение на количество партий, которые я могу отправлять в секунду. Макс одной партии. В случае дополнительных партий партия будет отброшена, что не является желательным.

Я могу использовать Thread.sleep() в течение секунды, чтобы я никогда не попадал в базу данных с более чем одной периодичностью в секунду.

Псевдокод выглядит следующим образом:

createBatch() 
sendBatch() 

То, что я пытаюсь сделать, это предел, сколько раз sendBatch() вызывается в секунду.

Могу ли я достичь этого, используя любую дроссельную библиотеку, а не используя Thread.sleep()?

Answer 1

Вы можете использовать RateLimiter из гуавы.
см: http://docs.guava-libraries.googlecode.com/git/javadoc/com/google/common/util/concurrent/RateLimiter.html

Answer 2

Я думаю, что это проблема ограничения количества ресурсов, которые могут быть использованы за раз. Попробуйте использовать метод объединения. в java вы можете использовать ExecutorService, чтобы сделать то же самое. См - http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html здесь приведен пример кода

class Worker implements Callable<String> { 
private int id; 
public Worker(int id) { 
    this.id = id; 
    System.out.println("im worker = " + id); 
} 
public String call() throws Exception { 
    System.out.println("Started some long operation - " + id); 
    Thread.sleep(1000); // only to simulate long running operation 
    System.out.println("Fiished long operation - " + id); 
    return null; 
} 

}

// главная mehtod

public class Main { 
private static final Logger logger = LoggerFactory.getLogger(Main.class); 
public static void main(String[] args) throws ExecutionException, InterruptedException { 
    final int poolSize = 100; 
    final int workerSize = 1000; 
    ExecutorService executor = Executors.newFixedThreadPool(poolSize); 
    Future[] futures = new Future[workerSize]; 
    Worker[] workers = new Worker[workerSize]; 
    for(int i = 0; i < workerSize; i++){ 
     workers[i] = new Worker(i); 
    } 
    System.out.println("finished creating workers================"); 
    for(int i = 0; i < workerSize; i++){ 
     futures[i] = executor.submit(workers[i]); 
    } 
    for (int i = 0; i < workerSize; i++){ 
     futures[i].get(); 
    } 
    System.out.println("Finished executing all"); 
    executor.shutdown(); 
} 

}