gaspersic/java-design-patterns
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

local variable type inference changes (#1043)

Browse Source 
local variable type inference changes for throttling design pattern
This commit is contained in:
GVSharma 2019-10-26 21:19:28 +05:30 committed by Ilkka Seppälä
parent 03e1e92b52
commit 954e7300e9
2 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
throttling/src/main/java/com/iluwatar/throttling/App.java
View File

@ -53,11 +53,11 @@ public class App {
* @param args main arguments
*/
public static void main(String[] args) {
CallsCount callsCount = new CallsCount();
Tenant adidas = new Tenant("Adidas", 5, callsCount);
Tenant nike = new Tenant("Nike", 6, callsCount);
var callsCount = new CallsCount();
var adidas = new Tenant("Adidas", 5, callsCount);
var nike = new Tenant("Nike", 6, callsCount);
ExecutorService executorService = Executors.newFixedThreadPool(2);
var executorService = Executors.newFixedThreadPool(2);
executorService.execute(() -> makeServiceCalls(adidas, callsCount));
executorService.execute(() -> makeServiceCalls(nike, callsCount));
@ -74,8 +74,8 @@ public class App {
* Make calls to the B2BService dummy API
*/
private static void makeServiceCalls(Tenant tenant, CallsCount callsCount) {
Throttler timer = new ThrottleTimerImpl(10, callsCount);
B2BService service = new B2BService(timer, callsCount);
var timer = new ThrottleTimerImpl(10, callsCount);
var service = new B2BService(timer, callsCount);
for (int i = 0; i < 20; i++) {
service.dummyCustomerApi(tenant);
// Sleep is introduced to keep the output in check and easy to view and analyze the results.

4
throttling/src/main/java/com/iluwatar/throttling/B2BService.java
View File

@ -48,8 +48,8 @@ class B2BService {
* @return customer id which is randomly generated
*/
public int dummyCustomerApi(Tenant tenant) {
String tenantName = tenant.getName();
long count = callsCount.getCount(tenantName);
var tenantName = tenant.getName();
var count = callsCount.getCount(tenantName);
LOGGER.debug("Counter for {} : {} ", tenant.getName(), count);
if (count >= tenant.getAllowedCallsPerSecond()) {
LOGGER.error("API access per second limit reached for: {}", tenantName);