feat: house keeping

Signed-off-by: Marcos Tischer Vallim <[email protected]>

Author: mvallim

amazon-sns-java-messaging-lib-template/src/test/java/com/amazon/sns/messaging/lib/concurrent/RingBufferBlockingQueueTest.java

@@ -38,166 +38,164 @@
 
 @SuppressWarnings({ "java:S2925", "java:S5778" })
 class RingBufferBlockingQueueTest {
-
+  
   @Test
   void testSuccess() {
     final ExecutorService producer = Executors.newSingleThreadScheduledExecutor();
-
+    
     final ScheduledExecutorService consumer = Executors.newSingleThreadScheduledExecutor();
-
+    
     final List<RequestEntry<Integer>> requestEntriesOut = new LinkedList<>();
-
+    
     final RingBufferBlockingQueue<RequestEntry<Integer>> ringBlockingQueue = new RingBufferBlockingQueue<>();
-
+    
     producer.submit(() -> {
       IntStream.range(0, 100_000).forEach(value -> {
         ringBlockingQueue.put(RequestEntry.<Integer>builder().withValue(value).build());
-        System.err.println("write: " + ringBlockingQueue.writeSequence());
       });
     });
-
+    
     consumer.scheduleAtFixedRate(() -> {
       while (!ringBlockingQueue.isEmpty()) {
         final List<RequestEntry<Integer>> requestEntries = new LinkedList<>();
-
+        
         while ((requestEntries.size() < 10) && Objects.nonNull(ringBlockingQueue.peek())) {
           final RequestEntry<Integer> take = ringBlockingQueue.take();
-          System.err.println("read: " + ringBlockingQueue.readSequence());
           requestEntries.add(take);
         }
-
+        
         requestEntriesOut.addAll(requestEntries);
       }
     }, 0, 100L, TimeUnit.MILLISECONDS);
-
+    
     await().pollInterval(5, TimeUnit.SECONDS).pollDelay(200, TimeUnit.MILLISECONDS).until(() -> {
       return (ringBlockingQueue.writeSequence() == 99_999) && (ringBlockingQueue.readSequence() == 100_000);
     });
-
+    
     producer.shutdown();
     consumer.shutdown();
-
+    
     assertThat(ringBlockingQueue.size(), is(0));
     assertThat(ringBlockingQueue.isEmpty(), is(true));
-
+    
     assertThat(requestEntriesOut, hasSize(100_000));
     requestEntriesOut.sort((a, b) -> a.getValue() - b.getValue());
-
+    
     for (int i = 0; i < 100_000; i++) {
       assertThat(requestEntriesOut.get(i).getValue(), is(i));
     }
   }
-
+  
   @Test
   void testSuccessWhenIsEmpty() {
     final RingBufferBlockingQueue<RequestEntry<Integer>> ringBlockingQueue = new RingBufferBlockingQueue<>();
-
+    
     final ExecutorService producer = Executors.newSingleThreadExecutor();
-
+    
     final ExecutorService consumer = Executors.newSingleThreadExecutor();
-
+    
     consumer.submit(() -> {
       assertThat(ringBlockingQueue.take().getValue(), is(0));
       assertThat(ringBlockingQueue.take().getValue(), is(1));
     });
-
+    
     await().pollDelay(2, TimeUnit.SECONDS).until(() -> true);
-
+    
     producer.submit(() -> {
       ringBlockingQueue.put(RequestEntry.<Integer>builder().withValue(0).build());
       ringBlockingQueue.put(RequestEntry.<Integer>builder().withValue(1).build());
     });
-
+    
     await().atMost(1, TimeUnit.MINUTES).until(() -> ringBlockingQueue.writeSequence() == 1);
     producer.shutdownNow();
-
+    
     await().atMost(1, TimeUnit.MINUTES).until(() -> ringBlockingQueue.readSequence() == 2);
     consumer.shutdownNow();
-
+    
     assertThat(ringBlockingQueue.isEmpty(), is(true));
   }
-
+  
   @Test
   void testSuccessWhenIsFull() {
     final RingBufferBlockingQueue<RequestEntry<Integer>> ringBlockingQueue = new RingBufferBlockingQueue<>(1);
-
+    
     final ExecutorService producer = Executors.newSingleThreadExecutor();
-
+    
     final ExecutorService consumer = Executors.newSingleThreadExecutor();
-
+    
     producer.submit(() -> {
       ringBlockingQueue.put(RequestEntry.<Integer>builder().withValue(0).build());
       ringBlockingQueue.put(RequestEntry.<Integer>builder().withValue(1).build());
     });
-
+    
     await().pollDelay(2, TimeUnit.SECONDS).until(() -> true);
-
+    
     consumer.submit(() -> {
       assertThat(ringBlockingQueue.take().getValue(), is(0));
       assertThat(ringBlockingQueue.take().getValue(), is(1));
     });
-
+    
     await().atMost(1, TimeUnit.MINUTES).until(() -> ringBlockingQueue.writeSequence() == 1);
     producer.shutdownNow();
-
+    
     await().atMost(1, TimeUnit.MINUTES).until(() -> ringBlockingQueue.readSequence() == 2);
     consumer.shutdownNow();
-
+    
     assertThat(ringBlockingQueue.isEmpty(), is(true));
   }
-
+  
   @Test
   void testFailOffer() {
     final RingBufferBlockingQueue<RequestEntry<Integer>> ringBlockingQueue = new RingBufferBlockingQueue<>();
     assertThrows(UnsupportedOperationException.class, () -> ringBlockingQueue.offer(RequestEntry.<Integer>builder().withValue(0).build()));
   }
-
+  
   @Test
   void testFailOfferWithParams() {
     final RingBufferBlockingQueue<RequestEntry<Integer>> ringBlockingQueue = new RingBufferBlockingQueue<>();
     assertThrows(UnsupportedOperationException.class, () -> ringBlockingQueue.offer(RequestEntry.<Integer>builder().withValue(0).build(), 1, TimeUnit.MILLISECONDS));
   }
-
+  
   @Test
   void testFailPoll() {
     final RingBufferBlockingQueue<RequestEntry<Integer>> ringBlockingQueue = new RingBufferBlockingQueue<>();
     assertThrows(UnsupportedOperationException.class, ringBlockingQueue::poll);
   }
-
+  
   @Test
   void testFailPollWithParams() {
     final RingBufferBlockingQueue<RequestEntry<Integer>> ringBlockingQueue = new RingBufferBlockingQueue<>();
     assertThrows(UnsupportedOperationException.class, () -> ringBlockingQueue.poll(1, TimeUnit.MILLISECONDS));
   }
-
+  
   @Test
   void testFailIterator() {
     final RingBufferBlockingQueue<RequestEntry<Integer>> ringBlockingQueue = new RingBufferBlockingQueue<>();
     assertThrows(UnsupportedOperationException.class, ringBlockingQueue::iterator);
   }
-
+  
   @Test
   void testFailAdd() {
     final RingBufferBlockingQueue<RequestEntry<Integer>> ringBlockingQueue = new RingBufferBlockingQueue<>();
     assertThrows(UnsupportedOperationException.class, () -> ringBlockingQueue.add(RequestEntry.<Integer>builder().withValue(0).build()));
   }
-
+  
   @Test
   void testFailRemainingCapacity() {
     final RingBufferBlockingQueue<RequestEntry<Integer>> ringBlockingQueue = new RingBufferBlockingQueue<>();
     assertThrows(UnsupportedOperationException.class, ringBlockingQueue::remainingCapacity);
   }
-
+  
   @Test
   void testFailDrainTo() {
     final RingBufferBlockingQueue<RequestEntry<Integer>> ringBlockingQueue = new RingBufferBlockingQueue<>();
     assertThrows(UnsupportedOperationException.class, () -> ringBlockingQueue.drainTo(Collections.emptyList()));
   }
-
+  
   @Test
   void testFailDrainToWithParams() {
     final RingBufferBlockingQueue<RequestEntry<Integer>> ringBlockingQueue = new RingBufferBlockingQueue<>();
     assertThrows(UnsupportedOperationException.class, () -> ringBlockingQueue.drainTo(Collections.emptyList(), 1));
   }
-
+  
 }