java rate limit logic [closed]

Question

It's difficult to tell what is being asked here. This question is ambiguous, vague, incomplete, overly broad, or rhetorical and cannot be reasonably answered in its current form. For help clarifying this question so that it can be reopened, visit the help center.

Closed 9 years ago.

I'm seeking algorithm to design multithreading application in java where each thread write data to db. I want to control the number of records written to db per second.

the application gets RPS (records per second) param and approximately generate those many load.

Answer 1

If you can use external libraries, guava has a RateLimiter class which probably does what you ask for:

Rate limiters are often used to restrict the rate at which some physical or logical resource is accessed. This is in contrast to Semaphore which restricts the number of concurrent accesses instead of the rate.

Answer 2

You could create a BlockingQueue of permit objects and have an extra helper thread that adds RPS number of additional permits to the queue once per second. Writing threads block on the queue and do not write until they successfully pop a permit off the top of the queue.