feat: require java 21

teletha · Jan 27, 2024 · 68ec5c7 · 68ec5c7
1 parent a5cf483
commit 68ec5c7
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 15 deletions.
diff --git a/src/main/java/viewtify/Viewtify.java b/src/main/java/viewtify/Viewtify.java
@@ -28,7 +28,6 @@
 import java.util.concurrent.CopyOnWriteArrayList;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
-import java.util.concurrent.ThreadFactory;
 import java.util.concurrent.TimeUnit;
 import java.util.function.BiConsumer;
 import java.util.function.BooleanSupplier;
@@ -116,18 +115,7 @@ public final class Viewtify {
     public static final Disposable Terminator = Disposable.empty();
 
     /** The thread pool. */
-    private static final ExecutorService pool = Executors.newCachedThreadPool(new ThreadFactory() {
-
-        /**
-         * {@inheritDoc}
-         */
-        @Override
-        public Thread newThread(Runnable runnable) {
-            Thread thread = new Thread(runnable);
-            thread.setDaemon(true);
-            return thread;
-        }
-    });
+    private static final ExecutorService pool = Executors.newVirtualThreadPerTaskExecutor();
 
     /** Executor for UI Thread. */
     public static final Consumer<Runnable> UIThread = Viewtify::inUI;

diff --git a/src/main/java/viewtify/ui/UITableColumn.java b/src/main/java/viewtify/ui/UITableColumn.java
@@ -22,6 +22,7 @@
 import javafx.scene.control.TableColumn;
 import javafx.scene.control.TableColumn.CellDataFeatures;
 import javafx.util.Callback;
+
 import kiss.Disposable;
 import kiss.I;
 import kiss.Signal;
@@ -134,7 +135,10 @@ public <T extends RowV> UITableColumn<RowV, ColumnV> modelByProperty(Class<T> ty
      */
     public UITableColumn<RowV, ColumnV> modelBySignal(WiseFunction<RowV, Signal<ColumnV>> mapper) {
         if (mapper != null) {
-            modelByProperty(v -> mapper.apply(v).to(new SmartProperty(), SmartProperty::set));
+            modelByProperty(v -> mapper.apply(v)
+                    .subscribeOn(Viewtify.WorkerThread)
+                    .on(Viewtify.UIThread)
+                    .to(new SmartProperty(), SmartProperty::set));
         }
         return this;
     }

diff --git a/src/project/java/viewtify/Project.java b/src/project/java/viewtify/Project.java
@@ -45,7 +45,7 @@ public class Project extends bee.api.Project {
                 * Browser manipulation
                 """);
 
-        require(SourceVersion.RELEASE_19, SourceVersion.RELEASE_17);
+        require(SourceVersion.RELEASE_21, SourceVersion.RELEASE_17);
 
         require("com.github.teletha", "altfx");
         require("com.github.teletha", "sinobu");