[1.1.1]

QueueManager tryAcquire interrupt self

Author: GoodforGod

src/main/java/io/api/etherscan/manager/impl/QueueManager.java

@@ -29,32 +29,27 @@ public QueueManager(int size, int queueResetTimeInSec, int delayInSec) {
         this(size, queueResetTimeInSec, delayInSec, size);
     }
 
-    public QueueManager(int size,
-                        int queueResetTimeInSec,
-                        int delayInSec,
-                        int initialSize) {
+    public QueueManager(int size, int queueResetTimeInSec, int delayInSec, int initialSize) {
         this(size,
                 (long) queueResetTimeInSec * 1000,
                 (long) delayInSec * 1000,
                 initialSize);
     }
 
-    public QueueManager(int size,
-                        long queueResetTimeInMillis,
-                        long delayInMillis,
-                        int initialSize) {
+    public QueueManager(int size, long queueResetTimeInMillis, long delayInMillis, int initialSize) {
         this.queueResetTimeInMillis = queueResetTimeInMillis;
         this.semaphore = new Semaphore(initialSize);
         this.executorService.scheduleAtFixedRate(releaseLocks(size), delayInMillis, queueResetTimeInMillis,
                 TimeUnit.MILLISECONDS);
     }
 
+    @SuppressWarnings("java:S899")
     @Override
     public void takeTurn() {
         try {
             semaphore.tryAcquire(queueResetTimeInMillis, TimeUnit.MILLISECONDS);
         } catch (InterruptedException e) {
-            // ignore
+            Thread.currentThread().interrupt();
         }
     }