reduce update priority

xzel23 · Apr 24, 2024 · 0188d4e · 0188d4e
1 parent 5bd2e58
commit 0188d4e
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 4 deletions.
diff --git a/fx-samples/src/main/java/com/dua3/fx/samples/LogPaneSample.java b/fx-samples/src/main/java/com/dua3/fx/samples/LogPaneSample.java
@@ -17,8 +17,8 @@ public class LogPaneSample extends Application {
         System.setProperty("java.util.logging.manager", "org.apache.logging.log4j.jul.LogManager");
     }
 
-    public static final int AVERAGE_SLEEP_MILLIS = 100;
-    public static final int LOG_BUFFER_SIZE = 1000;
+    public static final int AVERAGE_SLEEP_MILLIS = 10;
+    public static final int LOG_BUFFER_SIZE = 10000;
     private final org.slf4j.Logger SLF4J_LOGGER = LoggerFactory.getLogger("SLF4J." + getClass().getName());
     private final java.util.logging.Logger JUL_LOGGER = java.util.logging.Logger.getLogger("JUL." + getClass().getName());
     private final org.apache.logging.log4j.Logger LOG4J_LOGGER = org.apache.logging.log4j.LogManager.getLogger("LOG4J." + getClass().getName());

diff --git a/fx-util/src/main/java/com/dua3/fx/util/LogEntriesObservableList.java b/fx-util/src/main/java/com/dua3/fx/util/LogEntriesObservableList.java
@@ -21,7 +21,8 @@
 final class LogEntriesObservableList extends ObservableListBase<LogEntry> implements LogBuffer.LogBufferListener {
     private static final Logger LOG = LogManager.getLogger(LogEntriesObservableList.class);
 
-    private final LogBuffer buffer;
+    private static final long REST_TIME_IN_MS = 10;
+
     private volatile List<LogEntry> data = Collections.emptyList();
     private final AtomicInteger queuedRemoves = new AtomicInteger();
 
@@ -37,7 +38,6 @@ final class LogEntriesObservableList extends ObservableListBase<LogEntry> implem
      * @throws NullPointerException if the buffer is null
      */
     LogEntriesObservableList(LogBuffer buffer) {
-        this.buffer = buffer;
         buffer.addLogBufferListener(this);
 
         Thread updateThread = new Thread(() -> {
@@ -74,8 +74,14 @@ final class LogEntriesObservableList extends ObservableListBase<LogEntry> implem
                 } finally {
                     updateWriteLock.unlock();
                 }
+                try {
+                    Thread.sleep(REST_TIME_IN_MS);
+                } catch (InterruptedException e) {
+                    Thread.currentThread().interrupt();
+                }
             }
         }, "LogTableModel Update Thread");
+        updateThread.setPriority(Thread.NORM_PRIORITY - 1);
         updateThread.setDaemon(true);
         updateThread.start();
     }