不知道我是否完全理解，但我认为这可能有帮助。
使用Platform.runLater(…)是一个适当的方法。
避免泛滥FX应用程序线程的技巧是使用Atomicvariables来存储您感兴趣的值。在Platform.runLater(…)方法中，检索它并将其设置为标记值。 在你的后台线程中，更新Atomicvariables，但是如果它已经被设置回它的sentinel值，只发布一个新的Platform.runLater(…)。
我通过查看Task的源代码来了解这一点。 看看updateMessage(..)方法(在编写本文时为1131行)是如何实现的。
这是一个使用相同技术的例子。 这只是一个(繁忙)后台线程计数尽可能快，更新一个IntegerProperty。 观察者观察该属性并用新值更新AtomicInteger。 如果AtomicInteger的当前值是-1，则调度一个Platform.runLater()。
在Platform.runLater中，我检索AtomicInteger的值并使用它来更新一个Label，并在该过程中将该值设置回-1。 这表示我已准备好进行其他UI更新。
import java.text.NumberFormat; import java.util.concurrent.atomic.AtomicInteger; import javafx.application.Application; import javafx.application.Platform; import javafx.beans.property.IntegerProperty; import javafx.beans.property.SimpleIntegerProperty; import javafx.beans.value.ChangeListener; import javafx.beans.value.ObservableValue; import javafx.event.ActionEvent; import javafx.event.EventHandler; import javafx.scene.Scene; import javafx.scene.control.Button; import javafx.scene.control.Label; import javafx.scene.layout.AnchorPane; import javafx.stage.Stage; public class ConcurrentModel extends Application { @Override public void start(Stage primaryStage) { final AtomicInteger count = new AtomicInteger(-1); final AnchorPane root = new AnchorPane(); final Label label = new Label(); final Model model = new Model(); final NumberFormat formatter = NumberFormat.getIntegerInstance(); formatter.setGroupingUsed(true); model.intProperty().addListener(new ChangeListener() { @Override public void changed(final ObservableValue extends Number> observable, final Number oldValue, final Number newValue) { if (count.getAndSet(newValue.intValue()) == -1) { Platform.runLater(new Runnable() { @Override public void run() { long value = count.getAndSet(-1); label.setText(formatter.format(value)); } }); } } }); final Button startButton = new Button("Start"); startButton.setOnAction(new EventHandler() { @Override public void handle(ActionEvent event) { model.start(); } }); AnchorPane.setTopAnchor(label, 10.0); AnchorPane.setLeftAnchor(label, 10.0); AnchorPane.setBottomAnchor(startButton, 10.0); AnchorPane.setLeftAnchor(startButton, 10.0); root.getChildren().addAll(label, startButton); Scene scene = new Scene(root, 100, 100); primaryStage.setScene(scene); primaryStage.show(); } public static void main(String[] args) { launch(args); } public class Model extends Thread { private IntegerProperty intProperty; public Model() { intProperty = new SimpleIntegerProperty(this, "int", 0); setDaemon(true); } public int getInt() { return intProperty.get(); } public IntegerProperty intProperty() { return intProperty; } @Override public void run() { while (true) { intProperty.set(intProperty.get() + 1); } } } }
如果你真的想从UI中“驱动”后端：那就是节制后端实现的速度，以便看到所有的更新，可以考虑使用一个AnimationTimer 。 一个AnimationTimer有一个handle(...) ，每帧渲染一次。 因此，您可以阻止后端实现(例如使用阻塞队列)，并在每次调用handle方法时释放一次。 FX应用程序线程调用handle(...)方法。
handle(...)方法需要一个时间戳(纳秒)的参数，所以你可以使用它来进一步减慢更新，如果每帧一次太快的话。
例如：
import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue; import javafx.animation.AnimationTimer; import javafx.application.Application; import javafx.beans.property.LongProperty; import javafx.beans.property.SimpleLongProperty; import javafx.geometry.Insets; import javafx.geometry.Pos; import javafx.stage.Stage; import javafx.scene.Scene; import javafx.scene.control.Button; import javafx.scene.control.TextArea; import javafx.scene.layout.BorderPane; import javafx.scene.layout.HBox; public class Main extends Application { @Override public void start(Stage primaryStage) { final BlockingQueue messageQueue = new ArrayBlockingQueue<>(1); TextArea console = new TextArea(); Button startButton = new Button("Start"); startButton.setOnAction(event -> { MessageProducer producer = new MessageProducer(messageQueue); Thread t = new Thread(producer); t.setDaemon(true); t.start(); }); final LongProperty lastUpdate = new SimpleLongProperty(); final long minUpdateInterval = 0 ; // nanoseconds. Set to higher number to slow output. AnimationTimer timer = new AnimationTimer() { @Override public void handle(long now) { if (now - lastUpdate.get() > minUpdateInterval) { final String message = messageQueue.poll(); if (message != null) { console.appendText("\n" + message); } lastUpdate.set(now); } } }; timer.start(); HBox controls = new HBox(5, startButton); controls.setPadding(new Insets(10)); controls.setAlignment(Pos.CENTER); BorderPane root = new BorderPane(console, null, null, controls, null); Scene scene = new Scene(root,600,400); primaryStage.setScene(scene); primaryStage.show(); } private static class MessageProducer implements Runnable { private final BlockingQueue messageQueue ; public MessageProducer(BlockingQueue messageQueue) { this.messageQueue = messageQueue ; } @Override public void run() { long messageCount = 0 ; try { while (true) { final String message = "Message " + (++messageCount); messageQueue.put(message); } } catch (InterruptedException exc) { System.out.println("Message producer interrupted: exiting."); } } } public static void main(String[] args) { launch(args); } }