switched to using scheduler

Author: CodeManDev

build.gradle

@@ -3,7 +3,7 @@ plugins {
 }
 
 group = 'dev.codeman'
-version = '1.0-SNAPSHOT'
+version = '0.0.3'
 
 repositories {
     mavenCentral()

src/main/java/dev/codeman/smtc4j/SMTC4J.java

@@ -4,13 +4,17 @@
 import com.google.gson.GsonBuilder;
 
 import java.io.*;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
 
 public class SMTC4J {
 
     private static final Gson GSON = new GsonBuilder().create();
 
     private static boolean loaded = false;
-    private static Thread updateThread = null;
+
+    private static ScheduledExecutorService scheduler = null;
 
     private static MediaInfo lastMediaInfo = null;
     private static PlaybackState lastPlaybackState = null;
@@ -50,6 +54,17 @@ public static boolean isLoaded() {
         return loaded;
     }
 
+    private static synchronized ScheduledExecutorService getScheduler() {
+        if (scheduler == null || scheduler.isShutdown()) {
+            scheduler = Executors.newSingleThreadScheduledExecutor(r -> {
+                Thread t = new Thread(r, "SMTC4J-Executor");
+                t.setDaemon(true);
+                return t;
+            });
+        }
+        return scheduler;
+    }
+
     public static MediaInfo getCachedMediaInfo() {
         return lastMediaInfo;
     }
@@ -59,27 +74,17 @@ public static PlaybackState getCachedPlaybackState() {
     }
 
     public static void updateCache() {
+        checkIsLoaded();
+
         lastMediaInfo = parsedMediaInfo();
         lastPlaybackState = parsedPlaybackState();
     }
 
-    public static void startUpdateThread(long intervalMillis) {
-        if (updateThread != null && updateThread.isAlive())
-            return;
-
-        updateThread = new Thread(() -> {
-            while (true) {
-                try {
-                    updateCache();
-                    Thread.sleep(intervalMillis);
-                } catch (InterruptedException e) {
-                    Thread.currentThread().interrupt();
-                    break;
-                }
-            }
-        }, "SMTC4J-Update-Thread");
-        updateThread.setDaemon(true);
-        updateThread.start();
+    public static synchronized void startUpdateScheduler(long intervalMillis) {
+        checkIsLoaded();
+
+        ScheduledExecutorService exec = getScheduler();
+        exec.scheduleAtFixedRate(SMTC4J::updateCache, 0, intervalMillis, TimeUnit.MILLISECONDS);
     }
 
     public static MediaInfo parsedMediaInfo() {
@@ -122,6 +127,12 @@ public static void pressKey(MediaKey key) {
         pressMediaKey(key.ordinal());
     }
 
+    public static void scheduleKeyPress(MediaKey key) {
+        checkIsLoaded();
+
+        getScheduler().execute(() -> pressKey(key));
+    }
+
     private static void checkIsLoaded() {
         if (!isLoaded())
             throw new IllegalStateException("SMTC4J native library is not loaded.");

src/test/java/Main.java

@@ -16,7 +16,7 @@ public static void main(String[] args) {
             return;
         }
 
-        SMTC4J.startUpdateThread(1000);
+        SMTC4J.startUpdateScheduler(1000);
 
         int i = 0;
 
@@ -34,7 +34,7 @@ public static void main(String[] args) {
 
             if (i % 5 == 0) {
                 MediaKey keyToPress = MediaKey.values()[ThreadLocalRandom.current().nextInt(0, MediaKey.values().length)];
-                SMTC4J.pressKey(keyToPress);
+                SMTC4J.scheduleKeyPress(keyToPress);
                 System.out.println("Pressed key: " + keyToPress.name());
             }