JavaFXUIThreadManager.java
01 /*
02  * SPDX-License-Identifier: Apache-2.0
03  *
04  * Copyright 2008-2017 the original author or authors.
05  *
06  * Licensed under the Apache License, Version 2.0 (the "License");
07  * you may not use this file except in compliance with the License.
08  * You may obtain a copy of the License at
09  *
10  *     http://www.apache.org/licenses/LICENSE-2.0
11  *
12  * Unless required by applicable law or agreed to in writing, software
13  * distributed under the License is distributed on an "AS IS" BASIS,
14  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15  * See the License for the specific language governing permissions and
16  * limitations under the License.
17  */
18 package org.codehaus.griffon.runtime.javafx;
19 
20 import javafx.application.Platform;
21 import org.codehaus.griffon.runtime.core.threading.AbstractUIThreadManager;
22 
23 import javax.annotation.Nonnull;
24 import java.util.concurrent.ExecutionException;
25 import java.util.concurrent.FutureTask;
26 
27 import static java.util.Objects.requireNonNull;
28 
29 /**
30  @author Dean Iverson
31  */
32 public class JavaFXUIThreadManager extends AbstractUIThreadManager {
33     /**
34      * True if the current thread is the UI thread.
35      */
36     public boolean isUIThread() {
37         return Platform.isFxApplicationThread();
38     }
39 
40     @Override
41     public void runInsideUIAsync(@Nonnull Runnable runnable) {
42         requireNonNull(runnable, ERROR_RUNNABLE_NULL);
43         Platform.runLater(runnable);
44     }
45 
46     @Override
47     public void runInsideUISync(@Nonnull final Runnable runnable) {
48         requireNonNull(runnable, ERROR_RUNNABLE_NULL);
49         if (isUIThread()) {
50             runnable.run();
51         else {
52             FutureTask<Void> task = new FutureTask<>(() -> {
53                 try {
54                     runnable.run();
55                 catch (Throwable throwable) {
56                     getExceptionHandler().uncaughtException(Thread.currentThread(), throwable);
57                 }
58             }null);
59 
60             Platform.runLater(task);
61             try {
62                 task.get();
63             catch (InterruptedException | ExecutionException e) {
64                 getExceptionHandler().uncaughtException(Thread.currentThread(), e);
65             }
66         }
67     }
68 }