使用javafx更新UI
JavaFx如果在子線程中更新UI，不論是task還是runable都會報錯
java.lang.IllegalStateException: Not on FX application thread; currentThread =
這種情況可以使用下面的方法
1，Platform.runLater()
這個辦法在當前線程不是javafx的線程中，比如runnable，thread這些的，直接調用即可，runLater()不是線程阻塞型的，在javafx的主線程完全清空或者說空閑的時候，它才會執行，
|
1
2
3
4
5
6
7
|
Platform.runLater(new Runnable() { @Override public void run() { //更新JavaFX的主線程的代碼放在此處 p.cancelProgressBar(); } }); |
但是如果必須先執行這段代碼怎么辦呢，也有方法
1，future是個工作線程
他允許阻塞當前線程，執行線程中的代碼，在拿到返回值后，才會順序執行
|
1
2
3
4
5
6
7
8
9
10
11
12
13
|
// 定義一個FutureTask，然后 Plateform.runLater() 這個futuretask final FutureTask<String> query = new FutureTask<String>(new Callable<String>() { @Override public String call() throws Exception { // 新建一個窗口(方法中將創建stage) VcodeController vc = new VcodeController(); return vc.show(url4vcode); } }); Platform.runLater(query); // 重點 String vcode = query.get(); // 這樣就能獲取返回值 System.out.println(vcode); |
2，利用 CountDownLatch，直接阻塞當前的主線程，執行相關代碼業務
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
|
/** * Runs the specified {@link Runnable} on the * JavaFX application thread and waits for completion. * * @param action the {@link Runnable} to run * @throws NullPointerException if {@code action} is {@code null} */public static void runAndWait(Runnable action) { if (action == null) throw new NullPointerException("action"); // run synchronously on JavaFX thread if (Platform.isFxApplicationThread()) { action.run(); return; } // queue on JavaFX thread and wait for completion final CountDownLatch doneLatch = new CountDownLatch(1); Platform.runLater(() -> { try { action.run(); } finally { doneLatch.countDown(); } }); try { doneLatch.await(); } catch (InterruptedException e) { // ignore exception }} |
3.使用task線程的返回值
task是javafx實現的ui線程，他實現了futureTask和worlker線程，所以它既可以當普通線程來使用，也可以重寫返回值方法，實現ui界面的刷新
不過要說明的是，task的call方法，仍然是一個普通線程的方法，如果要實現在task中刷新ui界面，要在
scheduled(),succeeded(),running()任意一個方法中執行，就可以了，這樣就實現了再task的線程中，刷新界面的功能
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
|
package com.yz.readismqtest1; import javafx.concurrent.Task; public class deda { public static void main(String[] args) { Task task = new Task() { @Override protected Object call() throws Exception { //執行普通方法 return null; } @Override protected void scheduled() { //更新JavaFX的主線程的代碼放在此處 super.scheduled(); } @Override protected void succeeded() { //更新JavaFX的主線程的代碼放在此處 super.succeeded(); } @Override protected void running() { //更新JavaFX的主線程的代碼放在此處 super.running(); } }; }} |
JavaFX的并發編程與UI更新
JavaFX并發編程與UI更新
項目需求
根據項目需要，進行設備的并發測試，同時需要在界面上實時展示測試的結果
涉及到的技術
1、使用Observer的方式實現多個對象之間的通信（觀察者模式）
2、因為UI只有一個，需要在較短時間內接收并顯示大量的數據，所以使用了javafx.concurrent
3、線程池pool，減少對象的資源占用
上述技術的使用參考了大量的網絡資源和書籍內容，再次不進行一一列舉，感謝各位作者。
核心代碼
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
|
// 1、從線程池中獲取對象 ObjectPoolDrawUIService objPool = ObjectPoolDrawUIService.getInstance(); DrawUIService obj = (DrawUIService)objPool.getObject(); // 2、對象的初始化 produceCaseResult是需要更新的數據內容 ,i是行號信息，放在Object[]中進行傳遞 obj.init(new Object[]{produceCaseResult,i}, new EventHandler<WorkerStateEvent>() { @Override public void handle(WorkerStateEvent t) { Object[] objArray = (Object[])t.getSource().getValue(); testDetailList.set((int) objArray[1], (ProduceCaseResult)objArray[0]); // 4、因為是在線程中執行，所以 returnObject代碼不能跟在obj.restart后面，會導致被很快的restart objPool.returnObject(obj); } }); // 3、執行 obj.restart(); // 因為是從pool中獲取，可能已經執行完畢，所以restart以上代碼中需要特別注意，代碼4的位置，以下代碼為javafx.concurrent的核心代碼public class DrawUIService extends Service<Object[]>{ Object[] showData = {null,null}; public void init(Object[] showData, EventHandler<WorkerStateEvent> eventHandler) { this.showData = showData; setOnSucceeded(eventHandler); } @Override protected Task<Object[]> createTask() { return new Task<Object[]>() { @Override protected Object[] call() throws Exception { return showData; } }; }} |
以上為個人經驗，希望能給大家一個參考，也希望大家多多支持服務器之家。
原文鏈接：https://blog.csdn.net/qq_41886200/article/details/104050685
