Поток Javafx присоединяется к интерфейсу Light Light.Как мне синхронизировать потоки? - PullRequest
Новая
       4

Поток Javafx присоединяется к интерфейсу Light Light.Как мне синхронизировать потоки?

0 голосов
/ 05 октября 2018

У меня есть пользовательский интерфейс javafx, который имитирует светофор.У меня есть три нити для каждого из источников света, которые освещают каждый из соответствующих источников света, одновременно выключая остальные.Я запускаю потоки и использую метод join (), чтобы каждый поток мог загореться до того, как начнется другой поток.

Когда я использую Thread.join (), пользовательский интерфейс зависает, но я знаю, что потоки работают должным образом, потому что тестовая строка, которую я поместил в потоки, выполняется и ждет соответствующего времени, прежде чем будет выполнен другой.

Код выглядит следующим образом -

основной метод 

public void start(Stage primaryStage) {

    lightBoard.setArcWidth(10);
    lightBoard.setArcHeight(10);
    lightBoard.setFill(Color.DARKGREY);

    circleGreen.setFill(Color.WHITE);

    circleYellow.setFill(Color.WHITE);

    circleRed.setFill(Color.WHITE);

    Group group = new Group();
    group.getChildren().addAll(lightBoard, circleGreen, circleYellow, circleRed);
    BorderPane light = new BorderPane(group);
    light.setPadding( new Insets(20, 20, 20, 20) );

    GridPane layoutControls = new GridPane();
    layoutControls.setAlignment(Pos.CENTER);
    Button btnStart = new Button("Start");
    Button btnStop = new Button("Stop");
    layoutControls.add(btnStart, 0, 0);
    layoutControls.add(btnStop, 1, 0);

    BorderPane root = new BorderPane();
    root.setCenter(light);
    root.setBottom(layoutControls);

    Scene scene = new Scene(root, 380, 250);

    primaryStage.setTitle("Traffic Light Simulator");
    primaryStage.setScene(scene);
    primaryStage.show();

    // create and start threads

    Runnable lightGreen = new LightGreen();
    Runnable lightYellow = new LightYellow();
    Runnable lightRed = new LightRed();

    Thread threadGreen = new Thread(lightGreen);
    Thread threadYellow = new Thread(lightYellow);
    Thread threadRed = new Thread(lightRed);

    while(true){
        threadGreen  = new Thread(lightGreen);
        threadGreen.start();
        try{
            threadGreen.join();
        }
        catch(Exception e){

        }
        threadYellow = new Thread(lightYellow);
        threadYellow.start();
        try{
            threadYellow.join();
        }
        catch(Exception e){

        }
        threadRed =  new Thread(lightRed);
        threadRed.start();
        try{
            threadRed.join();
        }
        catch(Exception e){

        }
    }
}

классы потоков - 

class LightGreen implements Runnable {

    @Override
    public void run() {

        lock.lock();
        System.out.println("GREEn");
        circleGreen.setFill( Color.GREEN );
        circleYellow.setFill( Color.WHITE );
        circleRed.setFill( Color.WHITE );
        lock.unlock();

        try {
            Thread.sleep(3000L);
        } catch (InterruptedException ex) {
        }      
    }
}

class LightYellow implements Runnable {

    @Override
    public void run() {

        lock.lock();
        System.out.println("YELLOW");
        circleGreen.setFill( Color.WHITE );
        circleYellow.setFill( Color.YELLOW );
        circleRed.setFill( Color.WHITE );
        lock.unlock();
        try {
            Thread.sleep(3000L);
        } catch (InterruptedException ex) {
        }

    }
}

class LightRed implements Runnable {

    @Override
    public void run() {

        lock.lock();
        System.out.println("RED");
        circleGreen.setFill( Color.WHITE );
        circleYellow.setFill( Color.WHITE );
        circleRed.setFill( Color.RED );
        lock.unlock();
        try {
            Thread.sleep(3000L);
        } catch (InterruptedException ex) {
        }    
    }
}

Как я могу решить эту проблему?Мне сказали, что Platform.runlater можно использовать, но я не уверен, как его использовать.Мне нужно использовать многопоточность для этой задачи.

1 Ответ

0 голосов
/ 05 октября 2018

Вот краткая демонстрация того, как использовать JavaFx PauseTransition для обновления графического интерфейса: 

public class TrafficLight extends Application{

    private static final double RADIUS = 50;
    private static final double PAUSE = 1;
    private Circle  circleRed,  circleYellow,  circleGreen;
    private Color[] colors = {Color.RED, Color.YELLOW, Color.GREEN};
    private int onColor = 0;

    @Override
    public void start(Stage primaryStage) {

        circleRed = new Circle(RADIUS);
        circleRed.setFill(Color.WHITE);
        circleGreen = new Circle(RADIUS);
        circleGreen.setFill(Color.WHITE);
        circleYellow = new Circle(RADIUS);
        circleYellow.setFill(Color.WHITE);

        TilePane light = new TilePane(circleGreen, circleYellow, circleRed);
        light.setPadding( new Insets(20, 20, 20, 20) );
        Scene scene = new Scene(light, RADIUS*8, RADIUS*3);

        primaryStage.setTitle("Traffic Light Simulator");
        primaryStage.setScene(scene);
        primaryStage.show();
        update();
    }

    private void update() {

        PauseTransition pause = new PauseTransition(Duration.seconds(PAUSE));
        pause.setOnFinished(event ->{
            circleRed.setFill((onColor == 0) ?  colors[onColor] :Color.WHITE );
            circleYellow.setFill((onColor == 1) ? colors[onColor] :Color.WHITE);
            circleGreen.setFill((onColor == 2) ? colors[onColor] :Color.WHITE);
            onColor = ((onColor +1) >= colors.length) ? 0 : onColor+1;

            pause.play();
        });

        pause.play();
    }

    public static void main(String[] args) {
        launch(args);
    }
}

Редактировать Если вам нужно сделать это с потоками, хотя я думаю, что это не оптимальный инструмент, попробуйте эту технику: 

import javafx.application.Application;
import javafx.geometry.Insets;
import javafx.scene.Scene;
import javafx.scene.layout.TilePane;
import javafx.scene.paint.Color;
import javafx.scene.shape.Circle;
import javafx.stage.Stage;

public class TrafficLight extends Application{

    private static final double RADIUS = 50;

    private Circle  circleRed,  circleYellow,  circleGreen;
    private Color[] colors = {Color.RED, Color.YELLOW, Color.GREEN};
    private int onColor = 0;
    private static int threadNumber = 0, invokeThreadNumber =0;
    private static final Object myLock = new Object();

    @Override
    public void start(Stage primaryStage) {

        circleRed = new Circle(RADIUS);
        circleRed.setFill(Color.WHITE);
        circleGreen = new Circle(RADIUS);
        circleGreen.setFill(Color.WHITE);
        circleYellow = new Circle(RADIUS);
        circleYellow.setFill(Color.WHITE);

        TilePane light = new TilePane(circleGreen, circleYellow, circleRed);
        light.setPadding( new Insets(20, 20, 20, 20) );
        Scene scene = new Scene(light, RADIUS*8, RADIUS*3);

        primaryStage.setTitle("Traffic Light Simulator");
        primaryStage.setScene(scene);
        primaryStage.show();
        control();
    }

    private void control() {
        //invoke 3 synchronized control threads 
        new Thread( new ColorControl()).start();
        new Thread( new ColorControl()).start();
        new Thread( new ColorControl()).start();
    }

    private void update() {
        circleRed.setFill((onColor == 0) ?  colors[onColor] :Color.WHITE );
        circleYellow.setFill((onColor == 1) ? colors[onColor] :Color.WHITE);
        circleGreen.setFill((onColor == 2) ? colors[onColor] :Color.WHITE);
        onColor = ((onColor +1) >= colors.length) ? 0 : onColor+1;
    }

    class ColorControl implements Runnable {

        private int threadID;
        private static final long PAUSE = 1000;
        private int MAX_THREADS = 3;
        private boolean isStopped = false;

        ColorControl() {
            threadID = threadNumber ++;
        }

        void reset() {
            threadNumber = 0; invokeThreadNumber =0;
        }

        @Override
        public void run() {
            synchronized (myLock) {

                while (! isStopped  ) {
                    while (threadID != invokeThreadNumber) {
                        try {
                            myLock.wait();
                        } catch (InterruptedException e) {}
                    }
                    //do work here
                    update();

                    try {
                        Thread.sleep(PAUSE);
                    } catch (InterruptedException ex) { ex.printStackTrace();}
                    invokeThreadNumber++;
                    myLock.notifyAll();
                    if( invokeThreadNumber >= MAX_THREADS ) {
                        reset();
                    }
                }
            }
        }
    }

    public static void main(String[] args) {
        launch(args);
    }
}
...