메서드명 변경

Author: gunkim

rate-limiter/src/main/java/io/github/gunkim/ratelimiter/Application.java

@@ -17,7 +17,7 @@ public static void main(String[] args) {
     }
 
     private static void processRequest(TokenRateLimiterRateLimiter bucket) {
-        bucket.request(() -> System.out.println("Request"));
+        bucket.handleRequest(() -> System.out.println("Request"));
     }
 
     private static void sleep(long millis) {

rate-limiter/src/main/java/io/github/gunkim/ratelimiter/RateLimiter.java

@@ -1,5 +1,5 @@
 package io.github.gunkim.ratelimiter;
 
 public interface RateLimiter {
-    void request(Runnable request);
+    void handleRequest(Runnable request);
 }

rate-limiter/src/main/java/io/github/gunkim/ratelimiter/bucket/LeakyRateLimiterRateLimiter.java

@@ -38,7 +38,7 @@ public LeakyRateLimiterRateLimiter(int bucketSize, long scheduleInterval, int ba
     }
 
     @Override
-    public void request(Runnable request) {
+    public void handleRequest(Runnable request) {
         if (isFull()) {
             logger.trace("bucket is full!");
             return;

rate-limiter/src/main/java/io/github/gunkim/ratelimiter/bucket/TokenRateLimiterRateLimiter.java

@@ -34,7 +34,7 @@ public TokenRateLimiterRateLimiter(int bucketSize, long refillRate) {
     }
 
     @Override
-    public void request(Runnable request) {
+    public void handleRequest(Runnable request) {
         int currentTokens;
         do {
             currentTokens = tokens.get();

rate-limiter/src/main/java/io/github/gunkim/ratelimiter/window/FixedWindowRateLimiter.java

@@ -17,7 +17,7 @@ public FixedWindowRateLimiter(int maxRequestsPerWindow, int windowDurationMillis
     }
 
     @Override
-    public void request(Runnable request) {
+    public void handleRequest(Runnable request) {
         long currentTimeMillis = Instant.now().toEpochMilli();
         long currentWindowKey = currentTimeMillis / windowDurationMillis;
 

rate-limiter/src/test/java/io/github/gunkim/ratelimiter/bucket/TokenRateLimiterRateLimiterTest.java

@@ -24,7 +24,7 @@ void setUp() {
     @Test
     void 토큰이_없는_경우_요청이_무시된다() {
         try (var tokenBucket = new TokenRateLimiterRateLimiter(0, 20_000)) {
-            tokenBucket.request(request);
+            tokenBucket.handleRequest(request);
             Mockito.verify(request, never()).run();
         }
     }
@@ -33,7 +33,7 @@ void setUp() {
     void 토큰이_최대치일_때_모든_요청이_처리된다() {
         try (var tokenBucket = new TokenRateLimiterRateLimiter(10, 20_000)) {
             for (int i = 0; i < 10; i++) {
-                tokenBucket.request(request);
+                tokenBucket.handleRequest(request);
             }
             Mockito.verify(request, times(10)).run();
         }
@@ -43,7 +43,7 @@ void setUp() {
     void 토큰이_모두_사용된_후_나머지_요청이_무시된다() {
         try (var tokenBucket = new TokenRateLimiterRateLimiter(3, 20_000)) {
             for (int i = 0; i < 6; i++) {
-                tokenBucket.request(request);
+                tokenBucket.handleRequest(request);
             }
             Mockito.verify(request, times(3)).run();
         }
@@ -54,7 +54,7 @@ void setUp() {
         try (var tokenBucket = new TokenRateLimiterRateLimiter(100, 5_000)) {
             ExecutorService taskExecutor = Executors.newFixedThreadPool(10);
             for (int i = 0; i < 150; i++) {
-                taskExecutor.execute(() -> tokenBucket.request(request));
+                taskExecutor.execute(() -> tokenBucket.handleRequest(request));
             }
             taskExecutor.shutdown();
             taskExecutor.awaitTermination(1_000, TimeUnit.MILLISECONDS);

rate-limiter/src/test/java/io/github/gunkim/ratelimiter/window/FixedWindowRateLimiterTest.java

@@ -21,7 +21,7 @@ class FixedWindowRateLimiterTest {
     void window_size_이내_요청은_처리된다() {
         Runnable runnable = mock(Runnable.class);
         FixedWindowRateLimiter rateLimiter = createRateLimiter(10);
-        rateLimiter.request(runnable);
+        rateLimiter.handleRequest(runnable);
         verify(runnable, times(1)).run();
     }
 
@@ -52,7 +52,7 @@ private Runnable createRunnable(AtomicInteger counter, CountDownLatch countDownL
 
     private void sendRequests(FixedWindowRateLimiter rateLimiter, Runnable request, int requestCount) {
         for (int i = 0; i < requestCount; i++) {
-            rateLimiter.request(request);
+            rateLimiter.handleRequest(request);
         }
     }
 }