ゆっちのBlog

非同期処理を試してみた。

JavaFX

JavaFX をはじめてからいろいろ解らないことがあって思うように進まない。

９月、１０月は個人的にいろいろ面倒な季節であってそのうちにクリスマスやお正月と忙しくなる。

それでも少しだけでも！と今回は「JavaFX 2ではじめる、GUI開発　第14回非同期処理」を試してみる。

デスクトップアプリでは必ず必要となる技術だけに記事の解説も丁寧に書かれていました。

感謝感激！です。

非同期処理を実装するにあたって JavaFX には Task クラスがありそれが便利に使えます。

また、Platform.runLater(() –> { // … });

でスレッドを起こすことができてだいたい Swing でできていたことは可能なようです。

詳しくは上記の記事をご覧になることをお勧めします。

まだ、記事を読んだだけでいろいろ試してはいないのですが、「スレッド間のデータ交換」が面白そうだったので

実際に動かしてみました。

NetBeans プロジェクトのサンプルプログラムがダウンロードで提供されていたので非常に助かります。

ただ、ローカルのファイルを開くとあまり重い処理にはならないので解りにくかった。

そこで JavaFX と openJDK のサイトの HTML ファイルを取得して表示させるようにしてみました。

結局、あーでもない、こーでもないと下の動画のようなものができあがってしまいました。(^_^;)

おまけに自信の無い不安なソースコードも載せておきますので間違い等ありましたら教えていただければ幸いです。

package jp.yucchi.tryasinc;

import javafx.application.Application;
import javafx.fxml.FXMLLoader;
import javafx.scene.Parent;
import javafx.scene.Scene;
import javafx.stage.Stage;

public class TryAsync extends Application {
    
    @Override
    public void start(Stage stage) throws Exception {
        Parent root = FXMLLoader.load(getClass().getResource("FXMLDocument.fxml"));
        
        Scene scene = new Scene(root);
        stage.setTitle("非同期処理");
        stage.setScene(scene);
        stage.show();
    }

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

package jp.yucchi.tryasinc;

import javafx.application.Application;

import javafx.fxml.FXMLLoader;

import javafx.scene.Parent;

import javafx.scene.Scene;

import javafx.stage.Stage;

public class TryAsync extends Application {

@Override

public void start(Stage stage) throws Exception {

Parent root = FXMLLoader.load(getClass().getResource("FXMLDocument.fxml"));

Scene scene = new Scene(root);

stage.setTitle("非同期処理");

stage.setScene(scene);

stage.show();

}

public static void main(String[] args) {

launch(args);

}

package jp.yucchi.tryasinc;

import java.awt.Toolkit;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.lang.management.ManagementFactory;
import java.net.URL;
import java.util.ResourceBundle;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.logging.Level;
import java.util.logging.Logger;
import javafx.animation.KeyFrame;
import javafx.animation.Timeline;
import javafx.application.Platform;
import javafx.beans.value.ObservableValue;
import javafx.concurrent.Task;
import javafx.concurrent.Worker;
import javafx.concurrent.WorkerStateEvent;
import javafx.event.ActionEvent;
import javafx.fxml.FXML;
import javafx.fxml.Initializable;
import javafx.scene.control.Button;
import javafx.scene.control.Label;
import javafx.scene.control.ProgressIndicator;
import javafx.scene.control.TextArea;
import javafx.scene.control.TitledPane;
import javafx.stage.Stage;
import javafx.stage.WindowEvent;
import javafx.util.Duration;

public class FXMLDocumentController implements Initializable {

    @FXML
    private Label state;

    @FXML
    private Button startButton;

    @FXML
    private Button cancelButton;

    @FXML
    private TitledPane text_1;

    @FXML
    private TitledPane text_2;

    @FXML
    private TextArea textArea_1;

    @FXML
    private TextArea textArea_2;

    @FXML
    private ProgressIndicator progressIndicator;

    private final Works works = new Works();

    private ExecutorService executor;

    private final BlockingQueue<String> queue_javafx = new LinkedBlockingQueue<>();
    private final BlockingQueue<String> queue_openJDK = new LinkedBlockingQueue<>();

    private Timeline timer;

    private CompletableFuture<String> javaFX;
    private CompletableFuture<String> openJDK;
    private CompletableFuture<Void> doAllWorks;

    Task<Void> task;
    private StringBuilder builder_javafx;
    private StringBuilder builder_openJDK;

    @FXML
    public void handleStart(ActionEvent event) {
        
        textArea_1.clear();
        textArea_2.clear();
        startButton.setDisable(true);
        cancelButton.setDisable(false);
        int procs = ManagementFactory.getOperatingSystemMXBean().getAvailableProcessors();

        executor = Executors.newFixedThreadPool(procs);

        progressIndicator.setOpacity(1.0);

        javaFX = CompletableFuture.supplyAsync(() -> works.showJavaFX(), executor);
        openJDK = CompletableFuture.supplyAsync(() -> works.showOpenJDK(), executor);
        doAllWorks = CompletableFuture.allOf(javaFX, openJDK);

        task = new Task<Void>() {

            @Override
            protected Void call() throws Exception {

                doAllWorks.thenRunAsync(() -> {
                });
                doAllWorks.get();

                return null;

            }

        };
        new Thread(task).start();

        task.stateProperty().addListener((ObservableValue<? extends Worker.State> value, Worker.State oldState, Worker.State newState) -> {
            state.setText(oldState.toString() + " --> " + newState.toString());
        });

        Platform.runLater(() -> {

            task.setOnSucceeded((WorkerStateEvent e) -> {
                progressIndicator.setOpacity(0.0);
                System.out.println("Succeeded");
            });

            task.setOnFailed((WorkerStateEvent e) -> {
                System.out.println("Failed");
            });

            task.setOnRunning((WorkerStateEvent e) -> {
                System.out.println("Running");
            });

            task.setOnCancelled((WorkerStateEvent e) -> {
                System.out.println("Cancelled");
            });

            task.setOnScheduled((WorkerStateEvent e) -> {
                System.out.println("Scheduled");
            });

            timer = new Timeline(
                    new KeyFrame(
                            Duration.millis(100), (ActionEvent e) -> {
                                try {
                                    builder_javafx = new StringBuilder();
                                    builder_openJDK = new StringBuilder();

                                    while (!queue_javafx.isEmpty()) {
                                        String line = queue_javafx.take();
                                        builder_javafx.append(line);
                                        builder_javafx.append("\n");
                                    }

                                    while (!queue_openJDK.isEmpty()) {
                                        String line = queue_openJDK.take();
                                        builder_openJDK.append(line);
                                        builder_openJDK.append("\n");
                                    }

                                    if (!(task.isCancelled())) {
                                        textArea_1.appendText(builder_javafx.toString());
                                        textArea_2.appendText(builder_openJDK.toString());
                                    }
                                } catch (InterruptedException ex) {
                                }

                                if (task.isDone() || task.isCancelled()) {
                                    if (!(doAllWorks.isDone())) {
                                        executor.shutdownNow();
                                    }
                                    
                                    timer.stop();
                                    textArea_1.home();
                                    textArea_2.home();
                                    queue_javafx.clear();
                                    queue_openJDK.clear();
                                    builder_javafx = null;
                                    builder_openJDK = null;
                                    startButton.setDisable(false);
                                    cancelButton.setDisable(true);
                                    Toolkit.getDefaultToolkit().beep();
                                }

                                if (doAllWorks.isDone()) {
                                    executor.shutdown();
                                }
                            })
            );
            timer.setCycleCount(Timeline.INDEFINITE);
            timer.play();

        });
    }

    @FXML
    public void handleCancel(ActionEvent event) {
        if (task.isRunning()) {
            task.cancel();         
            textArea_1.appendText("\n\n<-----  キャンセルしました。  ----->");
            textArea_2.appendText("\n\n<-----  キャンセルしました。  ----->");
            progressIndicator.setOpacity(0.0);
            if (!(doAllWorks.isDone())) {
                executor.shutdownNow();
            }
        }
    }

    private class Works {

        private String showJavaFX() {

            BufferedReader in = null;
            try {
                in = new BufferedReader(new InputStreamReader(new URL("https://www.java.net//community/javafx").openStream()));
            } catch (IOException ex) {
                Logger.getLogger(FXMLDocumentController.class.getName()).log(Level.SEVERE, null, ex);
            }

            in.lines().forEach(e -> {
                queue_javafx.offer(e);
            });

            return null;

        }

        private String showOpenJDK() {

            BufferedReader in = null;
            try {
                in = new BufferedReader(new InputStreamReader(new URL("http://openjdk.java.net/").openStream()));
            } catch (IOException ex) {
                Logger.getLogger(FXMLDocumentController.class.getName()).log(Level.SEVERE, null, ex);
            }

            in.lines().forEach(e -> {
                queue_openJDK.offer(e);
            });

            return null;

        }

    }

    public void setStage(Stage stage) {
        stage.setOnCloseRequest((WindowEvent event) -> {
            executor.shutdown();
        });
    }

    @Override
    public void initialize(URL url, ResourceBundle rb) {
        cancelButton.setDisable(true);
    }

}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

200

201

202

203

204

205

206

207

208

209

210

211

212

213

214

215

216

217

218

219

220

221

222

223

224

225

226

227

228

229

230

231

232

233

234

235

236

237

238

239

240

241

242

243

244

245

246

247

248

249

250

251

252

253

254

255

package jp.yucchi.tryasinc;

import java.awt.Toolkit;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.lang.management.ManagementFactory;

import java.net.URL;

import java.util.ResourceBundle;

import java.util.concurrent.BlockingQueue;

import java.util.concurrent.CompletableFuture;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import java.util.concurrent.LinkedBlockingQueue;

import java.util.logging.Level;

import java.util.logging.Logger;

import javafx.animation.KeyFrame;

import javafx.animation.Timeline;

import javafx.application.Platform;

import javafx.beans.value.ObservableValue;

import javafx.concurrent.Task;

import javafx.concurrent.Worker;

import javafx.concurrent.WorkerStateEvent;

import javafx.event.ActionEvent;

import javafx.fxml.FXML;

import javafx.fxml.Initializable;

import javafx.scene.control.Button;

import javafx.scene.control.Label;

import javafx.scene.control.ProgressIndicator;

import javafx.scene.control.TextArea;

import javafx.scene.control.TitledPane;

import javafx.stage.Stage;

import javafx.stage.WindowEvent;

import javafx.util.Duration;

public class FXMLDocumentController implements Initializable {

@FXML

private Label state;

@FXML

private Button startButton;

@FXML

private Button cancelButton;

@FXML

private TitledPane text_1;

@FXML

private TitledPane text_2;

@FXML

private TextArea textArea_1;

@FXML

private TextArea textArea_2;

@FXML

private ProgressIndicator progressIndicator;

private final Works works = new Works();

private ExecutorService executor;

private final BlockingQueue<String> queue_javafx = new LinkedBlockingQueue<>();

private final BlockingQueue<String> queue_openJDK = new LinkedBlockingQueue<>();

private Timeline timer;

private CompletableFuture<String> javaFX;

private CompletableFuture<String> openJDK;

private CompletableFuture<Void> doAllWorks;

Task<Void> task;

private StringBuilder builder_javafx;

private StringBuilder builder_openJDK;

@FXML

public void handleStart(ActionEvent event) {

textArea_1.clear();

textArea_2.clear();

startButton.setDisable(true);

cancelButton.setDisable(false);

int procs = ManagementFactory.getOperatingSystemMXBean().getAvailableProcessors();

executor = Executors.newFixedThreadPool(procs);

progressIndicator.setOpacity(1.0);

javaFX = CompletableFuture.supplyAsync(() -> works.showJavaFX(), executor);

openJDK = CompletableFuture.supplyAsync(() -> works.showOpenJDK(), executor);

doAllWorks = CompletableFuture.allOf(javaFX, openJDK);

task = new Task<Void>() {

@Override

protected Void call() throws Exception {

doAllWorks.thenRunAsync(() -> {

});

doAllWorks.get();

return null;

}

};

new Thread(task).start();

task.stateProperty().addListener((ObservableValue<? extends Worker.State> value, Worker.State oldState, Worker.State newState) -> {

state.setText(oldState.toString() + " --> " + newState.toString());

});

Platform.runLater(() -> {

task.setOnSucceeded((WorkerStateEvent e) -> {

progressIndicator.setOpacity(0.0);

System.out.println("Succeeded");

});

task.setOnFailed((WorkerStateEvent e) -> {

System.out.println("Failed");

});

task.setOnRunning((WorkerStateEvent e) -> {

System.out.println("Running");

});

task.setOnCancelled((WorkerStateEvent e) -> {

System.out.println("Cancelled");

});

task.setOnScheduled((WorkerStateEvent e) -> {

System.out.println("Scheduled");

});

timer = new Timeline(

new KeyFrame(

Duration.millis(100), (ActionEvent e) -> {

try {

builder_javafx = new StringBuilder();

builder_openJDK = new StringBuilder();

while (!queue_javafx.isEmpty()) {

String line = queue_javafx.take();

builder_javafx.append(line);

builder_javafx.append("\n");

}

while (!queue_openJDK.isEmpty()) {

String line = queue_openJDK.take();

builder_openJDK.append(line);

builder_openJDK.append("\n");

}

if (!(task.isCancelled())) {

textArea_1.appendText(builder_javafx.toString());

textArea_2.appendText(builder_openJDK.toString());

}

} catch (InterruptedException ex) {

}

if (task.isDone() || task.isCancelled()) {

if (!(doAllWorks.isDone())) {

executor.shutdownNow();

}

timer.stop();

textArea_1.home();

textArea_2.home();

queue_javafx.clear();

queue_openJDK.clear();

builder_javafx = null;

builder_openJDK = null;

startButton.setDisable(false);

cancelButton.setDisable(true);

Toolkit.getDefaultToolkit().beep();

}

if (doAllWorks.isDone()) {

executor.shutdown();

}

})

);

timer.setCycleCount(Timeline.INDEFINITE);

timer.play();

});

}

@FXML

public void handleCancel(ActionEvent event) {

if (task.isRunning()) {

task.cancel();

textArea_1.appendText("\n\n<----- キャンセルしました。 ----->");

textArea_2.appendText("\n\n<----- キャンセルしました。 ----->");

progressIndicator.setOpacity(0.0);

if (!(doAllWorks.isDone())) {

executor.shutdownNow();

}

private class Works {

private String showJavaFX() {

BufferedReader in = null;

try {

in = new BufferedReader(new InputStreamReader(new URL("https://www.java.net//community/javafx").openStream()));

} catch (IOException ex) {

Logger.getLogger(FXMLDocumentController.class.getName()).log(Level.SEVERE, null, ex);

}

in.lines().forEach(e -> {

queue_javafx.offer(e);

});

return null;

}

private String showOpenJDK() {

BufferedReader in = null;

try {

in = new BufferedReader(new InputStreamReader(new URL("http://openjdk.java.net/").openStream()));

} catch (IOException ex) {

Logger.getLogger(FXMLDocumentController.class.getName()).log(Level.SEVERE, null, ex);

}

in.lines().forEach(e -> {

queue_openJDK.offer(e);

});

return null;

}

public void setStage(Stage stage) {

stage.setOnCloseRequest((WindowEvent event) -> {

executor.shutdown();

});

}

@Override

public void initialize(URL url, ResourceBundle rb) {

cancelButton.setDisable(true);

}

<?xml version="1.0" encoding="UTF-8"?>

<?import java.lang.*?>
<?import java.util.*?>
<?import javafx.geometry.*?>
<?import javafx.scene.*?>
<?import javafx.scene.control.*?>
<?import javafx.scene.layout.*?>

<AnchorPane id="AnchorPane" prefHeight="548.0" prefWidth="753.0" xmlns:fx="http://javafx.com/fxml/1" xmlns="http://javafx.com/javafx/2.2" fx:controller="jp.yucchi.tryasinc.FXMLDocumentController">
  <children>
    <HBox alignment="CENTER_RIGHT" prefHeight="61.0" prefWidth="725.0" AnchorPane.leftAnchor="14.0" AnchorPane.rightAnchor="14.0" AnchorPane.topAnchor="14.0">
      <children>
        <ProgressIndicator fx:id="progressIndicator" opacity="0.0" prefHeight="64.0" prefWidth="68.0" progress="-1.0" visible="true" />
        <Label id="status" fx:id="state" alignment="CENTER" prefHeight="30.0" prefWidth="220.0" text="">
          <HBox.margin>
            <Insets right="5.0" fx:id="x2" />
          </HBox.margin>
        </Label>
        <Button fx:id="cancelButton" alignment="CENTER" contentDisplay="LEFT" mnemonicParsing="false" onAction="#handleCancel" prefHeight="30.0" prefWidth="200.0" text="CANCEL" HBox.margin="$x2" />
        <Button fx:id="startButton" mnemonicParsing="false" onAction="#handleStart" prefHeight="30.0" prefWidth="200.0" text="START">
          <HBox.margin>
            <Insets right="3.0" fx:id="x1" />
          </HBox.margin>
        </Button>
      </children>
    </HBox>
    <Accordion prefHeight="448.0" prefWidth="725.0" AnchorPane.bottomAnchor="14.0" AnchorPane.leftAnchor="14.0" AnchorPane.rightAnchor="14.0" AnchorPane.topAnchor="86.0">
      <expandedPane>
        <TitledPane fx:id="text_2" animated="true" text="openJDK">
          <content>
            <AnchorPane id="Content" minHeight="0.0" minWidth="0.0" prefHeight="180.0" prefWidth="200.0">
              <children>
                <TextArea fx:id="textArea_2" prefHeight="400.0" prefWidth="721.0" wrapText="true" AnchorPane.bottomAnchor="0.0" AnchorPane.leftAnchor="0.0" AnchorPane.rightAnchor="0.0" AnchorPane.topAnchor="0.0" />
              </children>
            </AnchorPane>
          </content>
        </TitledPane>
      </expandedPane>
      <panes>
        <TitledPane fx:id="text_1" animated="true" prefHeight="435.0" prefWidth="725.0" text="JavaFX  Java.net">
          <content>
            <AnchorPane id="Content" minHeight="0.0" minWidth="0.0" prefHeight="180.0" prefWidth="200.0">
              <children>
                <TextArea fx:id="textArea_1" prefHeight="402.0" prefWidth="721.0" wrapText="true" AnchorPane.bottomAnchor="-2.0" AnchorPane.leftAnchor="0.0" AnchorPane.rightAnchor="0.0" AnchorPane.topAnchor="0.0" />
              </children>
            </AnchorPane>
          </content>
        </TitledPane>
        <fx:reference source="text_2" />
      </panes>
    </Accordion>
  </children>
</AnchorPane>

<?xml version="1.0" encoding="UTF-8"?>

<?import java.lang.*?>

<?import java.util.*?>

<?import javafx.geometry.*?>

<?import javafx.scene.*?>

<?import javafx.scene.control.*?>

<?import javafx.scene.layout.*?>

<HBox.margin>

</HBox.margin>

</Label>

<HBox.margin>

</HBox.margin>

</Button>

</children>

</HBox>

</children>

</AnchorPane>

</content>

</TitledPane>

</expandedPane>

<panes>

</children>

</AnchorPane>

</content>

</TitledPane>

<fx:reference source="text_2" />

</panes>

</Accordion>

</children>

</AnchorPane>

もっといろいろ遊んでみたいけど解らないことが多すぎて調べる時間が足らない。(>_<｡)

一日の時間が私だけ３０時間にならないかと思う今日この頃です。

あっ、もう一つおまけに Java 8 を使っている新しい物好きな人は気が向いたらためしてみてください。

Webstart: click to launch this app as webstart （Java 8 実行環境必須）

Hatena タグ: JavaFX

TAGS: JavaFX | 2013年9月12日10:36 PM | Comment : 0

非同期処理を試してみた。

Recent Comments

Java

NetBeans

カテゴリー

アーカイブ

RSS FEED

ねこび～ん

メタ情報

ゆっちのカレンダー

2013年9月
月	火	水	木	金	土	日
« 8月				10月 »
						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

ゆっちのBlog

非同期処理を試してみた。

Popular post ranking

Recent Comments

Java

NetBeans

カテゴリー

アーカイブ

RSS FEED

ねこび～ん

メタ情報

ゆっちのカレンダー