Cassandra – Is there a way to limit number of async queries?

by

You can use a semaphore to throttle the number of concurrent queries:

final Semaphore semaphore = new Semaphore(numberOfConcurrentQueries);
...
semaphore.acquire();
try {
    ResultSetFuture future = session.executeAsync("...");
    Futures.addCallback(future, new FutureCallback<ResultSet>() {
        @Override
        public void onSuccess(ResultSet result) {
            semaphore.release();
        }

        @Override
        public void onFailure(Throwable t) {
            semaphore.release();
        }
    });
} catch (Exception e) {
    semaphore.release();
}

But at the end of the day it’s not so different: instead of getting a NoHostAvailableException when you exceed the capacity, the semaphore will block (or throw if you use a timed version of acquire). So you’ll probably want to apply backpressure to the component that triggers these queries as well.

You might also want to tune your connection pools to adjust the capacity, see our docs (that’s for 2.1, use the dropdown at the top of the page if you’re on 2.0).

More Related Contents:

  1. java.awt.EventQueue.invokeLater explained
  2. How to asynchronously call a method in Java
  3. How do you create an asynchronous HTTP request in JAVA?
  4. Return a value from AsyncTask in Android [duplicate]
  5. Asynchronous IO in Java?
  6. What are the best use cases for Akka framework [closed]
  7. Pausing/stopping and starting/resuming Java TimerTask continuously?
  8. Is asynchronous jdbc call possible?
  9. How to use JUnit to test asynchronous processes
  10. TaskSchedulerImpl: Initial job has not accepted any resources;
  11. non-blocking IO vs async IO and implementation in Java
  12. Core pool size vs maximum pool size in ThreadPoolExecutor
  13. A Simple AJAX with JSP example
  14. Why is CompletableFuture.supplyAsync succeeding a random number of times?
  15. RxJava Fetching Observables In Parallel
  16. Spring Boot @Async method in controller is executing synchronously
  17. Sync version of async method
  18. com.datastax.driver.core.exceptions.InvalidQueryException: unconfigured table schema_keyspaces
  19. Will a chain of method calls (CompletableFuture API) execute asynchronously if the first method in a chain is asynchronous?
  20. How to read XML using XPath in Java
  21. What is the purpose of Mavens dependency declarations classifier property?
  22. How to save an image in Android Q using MediaStore?
  23. Embedding resources (images, sound bits, etc) into a Java project then use those resources
  24. Why doesn’t this regex work as expected in Java?
  25. SQLiteOpenHelper failing to call onCreate?
  26. Draw arc with 2 points and center of the circle
  27. Firebase can’t save retrieved data to ArrayList
  28. Merging Two JSON Documents Using Jackson
  29. Java heap space in netbeans.. but I’ve increased the heap size already!
  30. Limitation while generating excel drop down list with Apache POI

Leave a Comment