Eliminating shutdown noise from interruption in schedule tasks execut…

…or. (#45)

CHANGELOG.md

@@ -5,6 +5,12 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [1.12.3] - 2024-01-11
+
+### Fixed
+
+* Eliminating shutdown noise from interruption in schedule tasks executor.
+
 ## [1.12.2] - 2024-01-05
 
 ### Fixed

gradle.properties

@@ -1 +1 @@
-version=1.12.2
+version=1.12.3

tw-base-utils/src/main/java/com/transferwise/common/baseutils/concurrency/SimpleScheduledTaskExecutor.java

@@ -79,7 +79,16 @@ public void start() {
 
     executorService.submit(() -> {
       while (!stopRequested) {
-        ScheduledTask scheduledTask = ExceptionUtils.doUnchecked(() -> taskQueue.poll(tick.toMillis(), TimeUnit.MILLISECONDS));
+        ScheduledTask scheduledTask = null;
+        try {
+          scheduledTask = taskQueue.poll(tick.toMillis(), TimeUnit.MILLISECONDS);
+        } catch (InterruptedException e) {
+          if (stopRequested) {
+            break;
+          } else {
+            throw new RuntimeException(e);
+          }
+        }
         if (log.isDebugEnabled() && scheduledTask == null) {
           if (nextTaskLoggingRateLimiter.tryAcquire()) {
             var nextScheduledTask = taskQueue.peek();