新・Java入門編44:Executorフレームワーク2（ExecutorService）

package jp.paiza.thread;

import java.util.concurrent.*;

public class TEST {

    public static void main(String... args) {
        
        Runnable t1 = () -> {
            for (var i = 0; i < 5; i++) {
                System.out.println("a" + i);
                try {
                    Thread.sleep(50);
                } catch (InterruptedException e) {}
            }
        };
        
        Runnable t2 = () -> {
            for (var i = 0; i < 5; i++) {
                try {
                    Thread.sleep(30);
                } catch (InterruptedException e) {}
                System.out.println("b" + i);
                try {
                    Thread.sleep(40);
                } catch (InterruptedException e) {}
            }
        };
        
        Callable<Boolean> t3 = () -> {
            for (var i = 0; i < 5; i++) {
                System.out.println("c" + i);
                try {
                    Thread.sleep(90);
                } catch (InterruptedException e) {}
            }
            return true;
        };


        // スレッドを実行する
        
    }
}

package jp.paiza.thread;

import java.util.concurrent.*;

public class TEST {

    public static void main(String... args) {
        
        Runnable t1 = () -> {
            for (var i = 0; i < 5; i++) {
                System.out.println("a" + i);
                try {
                    Thread.sleep(50);
                } catch (InterruptedException e) {}
            }
        };
        
        Runnable t2 = () -> {
            for (var i = 0; i < 5; i++) {
                try {
                    Thread.sleep(30);
                } catch (InterruptedException e) {}
                System.out.println("b" + i);
                try {
                    Thread.sleep(40);
                } catch (InterruptedException e) {}
            }
        };
        
        Callable<Boolean> t3 = () -> {
            for (var i = 0; i < 5; i++) {
                System.out.println("c" + i);
                try {
                    Thread.sleep(90);
                } catch (InterruptedException e) {}
            }
            return true;
        };


        // スレッドを実行する
        
    }
}

package jp.paiza.thread;

import java.util.concurrent.*;

public class TEST {

    public static void main(String... args) {
        
        Runnable t1 = () -> {
            for (var i = 0; i < 5; i++) {
                System.out.println("a" + i);
                try {
                    Thread.sleep(50);
                } catch (InterruptedException e) {}
            }
        };
        
        Runnable t2 = () -> {
            for (var i = 0; i < 5; i++) {
                System.out.println("b" + i);
                try {
                    Thread.sleep(40);
                } catch (InterruptedException e) {}
            }
        };
        
        Runnable t3 = () -> {
            for (var i = 0; i < 5; i++) {
                System.out.println("c" + i);
                try {
                    Thread.sleep(90);
                } catch (InterruptedException e) {}
            }
        };


        // ExecutorServiceインターフェースを用いてスレッドの管理を行う
    

        try {
            f1.get();
            f2.get();
            f3.get();
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        } finally {
            exe.shutdown();
        }
    }    
}

package jp.paiza.thread;

import java.util.concurrent.*;

public class TEST {

    public static void main(String... args) {
        
        Runnable t1 = () -> {
            for (var i = 0; i < 5; i++) {
                System.out.println("a" + i);
                try {
                    Thread.sleep(50);
                } catch (InterruptedException e) {}
            }
        };
        
        Runnable t2 = () -> {
            for (var i = 0; i < 5; i++) {
                System.out.println("b" + i);
                try {
                    Thread.sleep(40);
                } catch (InterruptedException e) {}
            }
        };
        
        Runnable t3 = () -> {
            for (var i = 0; i < 5; i++) {
                System.out.println("c" + i);
                try {
                    Thread.sleep(90);
                } catch (InterruptedException e) {}
            }
        };


        // ExecutorServiceインターフェースを用いてスレッドの管理を行う
    

        try {
            f1.get();
            f2.get();
            f3.get();
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        } finally {
            exe.shutdown();
        }
    }    
}

package jp.paiza.thread;

import java.util.concurrent.*;

public class TEST {

    public static void main(String... args) {
        
        Runnable t1 = () -> {
            for (var i = 0; i < 5; i++) {
                System.out.println("a" + i);
                try {
                    Thread.sleep(50);
                } catch (InterruptedException e) {}
            }
        };
        
        Runnable t2 = () -> {
            for (var i = 0; i < 5; i++) {
                try {
                    Thread.sleep(30);
                } catch (InterruptedException e) {}
                System.out.println("b" + i);
                try {
                    Thread.sleep(40);
                } catch (InterruptedException e) {}
            }
        };
        
        Runnable t3 = () -> {
            try {
                Thread.sleep(80);
            } catch (InterruptedException e) {}
            for (var i = 0; i < 5; i++) {
                System.out.println("c" + i);
                try {
                    Thread.sleep(60);
                } catch (InterruptedException e) {}
            }
        };


        // ExecutorServiceインタフェースを用いてスレッドの管理を行う


        try {
            f1.get();
            f2.get();
            f3.get();
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        } finally {
            exe.shutdown();
        }
    }   
}

package jp.paiza.thread;

import java.util.concurrent.*;

public class TEST {

    public static void main(String... args) {
        
        Runnable t1 = () -> {
            for (var i = 0; i < 5; i++) {
                System.out.println("a" + i);
                try {
                    Thread.sleep(50);
                } catch (InterruptedException e) {}
            }
        };
        
        Runnable t2 = () -> {
            for (var i = 0; i < 5; i++) {
                try {
                    Thread.sleep(30);
                } catch (InterruptedException e) {}
                System.out.println("b" + i);
                try {
                    Thread.sleep(40);
                } catch (InterruptedException e) {}
            }
        };
        
        Runnable t3 = () -> {
            try {
                Thread.sleep(80);
            } catch (InterruptedException e) {}
            for (var i = 0; i < 5; i++) {
                System.out.println("c" + i);
                try {
                    Thread.sleep(60);
                } catch (InterruptedException e) {}
            }
        };


        // ExecutorServiceインタフェースを用いてスレッドの管理を行う


        try {
            f1.get();
            f2.get();
            f3.get();
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        } finally {
            exe.shutdown();
        }
    }   
}

この動画を見るには

paiza会員登録のうえ

有料会員登録が必要です

問題ログインすると模範解答や入力を見ることができます

演習課題「newSingleThreadExecutorを使ってみよう」

ExecutorServiceインタフェースのnewSingleThreadExecutorを使用してt1、t2、t3を1つのスレッドで実行し、各アルファベッド（a、b、c）が混ざることなく出力されるようにしてください。
また、ExecutorServiceのsubmitメソッドを使用して、結果をあらわすFutureインスタンスを取得しましょう。各Futureインスタンスは以下のようにしてください。
t1: Runnableを引数に取り、タスクが正常に完了するとnullを返す。
t2: RunnableとTを引数に取り、タスクが正常に完了するとTを返す。
t3: Callableを引数に取り、タスクが正常に完了するとタスクの実行結果を返す。

なお、コンパイルコマンドについて理解できれいれば、以下のコマンドをコピーして利用してください。

javac -d classes/jp.paiza.thread -p classes source/jp.paiza.thread/module-info.java source/jp.paiza.thread/jp/paiza/thread/*.java

また、実行コマンドについて理解できていれば、以下の実行コマンドをコピーして利用してください。

java -p classes --module jp.paiza.thread/jp.paiza.thread.TEST

期待する出力値

a0
a1
a2
a3
a4
f1:null
b0
b1
b2
b3
b4
f2:true
c0
c1
c2
c3
c4
f3:true

問題ログインすると模範解答や入力を見ることができます

演習課題「newFixedThreadPoolを使ってみよう」

ExecutorServiceインターフェースのnewFixedThreadPoolを使用してRunnable t1、t2、t3を2つのスレッドで実行し、2種のアルファベッド（a、b）が混ざり、cが混ざることなく出力されるようにしてください。

なお、コンパイルコマンドについて理解できれいれば、以下のコマンドをコピーして利用してください。

javac -d classes/jp.paiza.thread -p classes source/jp.paiza.thread/module-info.java source/jp.paiza.thread/jp/paiza/thread/*.java

また、実行コマンドについて理解できていれば、以下の実行コマンドをコピーして利用してください。

java -p classes --module jp.paiza.thread/jp.paiza.thread.TEST

期待する出力値

b0
a0
b1
a1
b2
a2
b3
a3
b4
a4
c0
c1
c2
c3
c4

問題ログインすると模範解答や入力を見ることができます

演習課題「newCachedThreadPoolを使ってみよう」

ExecutorServiceインターフェースのnewCachedThreadPoolを使用してRunnable t1、t2、t3を3つのスレッドで実行し、各アルファベッド（a、b、c）全てが混ざって出力されるようにしてください。

なお、コンパイルコマンドについて理解できれいれば、以下のコマンドをコピーして利用してください。

javac -d classes/jp.paiza.thread -p classes source/jp.paiza.thread/module-info.java source/jp.paiza.thread/jp/paiza/thread/*.java

また、実行コマンドについて理解できていれば、以下の実行コマンドをコピーして利用してください。

java -p classes --module jp.paiza.thread/jp.paiza.thread.TEST

期待する出力値

a0
b0
a1
c0
b1
a2
c1
a3
b2
c2
a4
b3
c3
b4
c4

Tips

動画へ戻る

次のチャプターへ前のチャプターへ

※有料会員になるとこの動画をご利用いただけます

詳しい説明を読む

＃03:Executorフレームワーク2（ExecutorService）

このチャプターでは、ExecutorフレームワークにおけるExecutorServiceついて学習します。

PaizaCloud

ブラウザを開くだけでエディタ、Webサーバ、DB等の開発環境が整うクラウド開発環境PaizaCloudクラウドIDE。

PaizaCloud
https://paiza.cloud/ja/

API

インタフェースExecutorService
https://docs.oracle.com/javase/jp/17/docs/api/java.base/java/util/concurrent/ExecutorService.html

クラスExecutors
https://docs.oracle.com/javase/jp/17/docs/api/java.base/java/util/concurrent/Executors.html

インタフェースFuture
https://docs.oracle.com/javase/jp/17/docs/api/java.base/java/util/concurrent/Future.html

インタフェースCallable
https://docs.oracle.com/javase/jp/17/docs/api/java.base/java/util/concurrent/Callable.html

コンパイルコマンド・実行コマンド

コンパイルコマンド

javac -d classes/jp.paiza.thread -p classes source/jp.paiza.thread/module-info.java source/jp.paiza.thread/jp/paiza/thread/*.java

実行コマンド
java -p classes --module jp.paiza.thread/jp.paiza.thread.A

完成コード

A.java

package jp.paiza.thread;

import java.util.concurrent.*;

public class A {

    public static void main(String... args) {
        
        Runnable t1 = () -> {
            for (var i = 0; i < 5; i++) {
                System.out.println("+");
                try {
                    Thread.sleep(200);
                } catch (InterruptedException e) {}
            }
        };
        
        Runnable t2 = () -> {
            for (var i = 0; i < 5; i++) {
                System.out.println("*");
                try {
                    Thread.sleep(200);
                } catch (InterruptedException e) {}
            }
        };
        
        Callable<Boolean> t3 = () -> {
            for (var i = 0; i < 5; i++) {
                System.out.println("-");
                try {
                    Thread.sleep(200);
                } catch (InterruptedException e) {}
            }
            return true;
        };
        
        var exe = Executors.newCachedThreadPool();
        
        Future<?> f1 = exe.submit(t1);
        Future<Boolean> f2 = exe.submit(t2, true);
        Future<Boolean> f3 = exe.submit(t3);
        
        try {
            System.out.println("f1:" + f1.get());
            System.out.println("f2:" + f2.get());
            System.out.println("f3:" + f3.get());
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        } finally {
            exe.shutdown();
        }
    }
}

プログラミング学習 > Java > 新・Java入門編 > 新・Java入門編44: 並行・並列処理についてさらに学習しよう > Executorフレームワーク2（ExecutorService）

新・Java入門編44: 並行・並列処理についてさらに学習しよう

演習課題「newSingleThreadExecutorを使ってみよう」

期待する出力値

演習課題「newFixedThreadPoolを使ってみよう」

期待する出力値

演習課題「newCachedThreadPoolを使ってみよう」

期待する出力値

＃03:Executorフレームワーク2（ExecutorService）

PaizaCloud

関連するコンテンツ

API

コンパイルコマンド・実行コマンド

完成コード