[loxone] Fix for #8693 - removed deadlock (#9624)

Signed-off-by: Pawel Pieczul <pieczul@gmail.com>

diff --git a/bundles/org.openhab.binding.loxone/src/main/java/org/openhab/binding/loxone/internal/LxServerHandler.java b/bundles/org.openhab.binding.loxone/src/main/java/org/openhab/binding/loxone/internal/LxServerHandler.java
index 560292e69a49126b85ad5d0bbcd37a146ab8e466..aa6b9d58dedc0c91a669c1f213f21a91b39b48a4 100644 (file)
--- a/bundles/org.openhab.binding.loxone/src/main/java/org/openhab/binding/loxone/internal/LxServerHandler.java
+++ b/bundles/org.openhab.binding.loxone/src/main/java/org/openhab/binding/loxone/internal/LxServerHandler.java
@@ -24,11 +24,11 @@ import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
-import java.util.concurrent.ConcurrentLinkedQueue;
+import java.util.concurrent.BlockingQueue;
+import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.concurrent.atomic.AtomicInteger;
-import java.util.concurrent.locks.Condition;
 import java.util.concurrent.locks.Lock;
 import java.util.concurrent.locks.ReentrantLock;
 
@@ -94,14 +94,12 @@ public class LxServerHandler extends BaseThingHandler implements LxServerHandler
     private int debugId = 0;
     private Thread monitorThread;
     private final Lock threadLock = new ReentrantLock();
-    private final Lock queueUpdatedLock = new ReentrantLock();
-    private final Condition queueUpdated = queueUpdatedLock.newCondition();
     private AtomicBoolean sessionActive = new AtomicBoolean(false);
 
     // Data structures
     private final Map<LxUuid, LxControl> controls = new HashMap<>();
     private final Map<ChannelUID, LxControl> channels = new HashMap<>();
-    private final ConcurrentLinkedQueue<LxStateUpdate> stateUpdateQueue = new ConcurrentLinkedQueue<>();
+    private final BlockingQueue<LxStateUpdate> stateUpdateQueue = new LinkedBlockingQueue<>();
 
     private LxDynamicStateDescriptionProvider dynamicStateDescriptionProvider;
     private final Logger logger = LoggerFactory.getLogger(LxServerHandler.class);
@@ -467,12 +465,6 @@ public class LxServerHandler extends BaseThingHandler implements LxServerHandler
      */
     void queueStateUpdate(LxUuid uuid, Object value) {
         stateUpdateQueue.add(new LxStateUpdate(uuid, value));
-        queueUpdatedLock.lock();
-        try {
-            queueUpdated.signalAll();
-        } finally {
-            queueUpdatedLock.unlock();
-        }
     }
 
     /**
@@ -672,21 +664,13 @@ public class LxServerHandler extends BaseThingHandler implements LxServerHandler
         private void processStateUpdates() throws InterruptedException {
             while (sessionActive.get()) {
                 logger.debug("[{}] Sleeping for {} seconds.", debugId, bindingConfig.keepAlivePeriod - elapsed);
-                queueUpdatedLock.lock();
-                try {
-                    if (!queueUpdated.await(bindingConfig.keepAlivePeriod - elapsed, TimeUnit.SECONDS)) {
-                        sendKeepAlive();
-                        continue;
-                    }
-                } finally {
-                    queueUpdatedLock.unlock();
-                }
+                LxStateUpdate update = stateUpdateQueue.poll(bindingConfig.keepAlivePeriod - elapsed, TimeUnit.SECONDS);
                 elapsed = Duration.between(lastKeepAlive, Instant.now()).getSeconds();
-                if (elapsed >= bindingConfig.keepAlivePeriod) {
+                if (update == null || elapsed >= bindingConfig.keepAlivePeriod) {
                     sendKeepAlive();
+                    elapsed = 0;
                 }
-                LxStateUpdate update;
-                while ((update = stateUpdateQueue.poll()) != null && sessionActive.get()) {
+                if (update != null) {
                     updateStateValue(update);
                 }
             }