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

package jp.paiza.thread;

import java.time.*;
import java.time.format.*;
import java.util.concurrent.*;

public class TEST {

    private static long startTime = System.currentTimeMillis();

    public static void main(String... args) {
        Runnable t1 = () -> {
            try {
                System.out.println(printStartDiff() + "秒");
                TimeUnit.SECONDS.sleep(2);
            } catch (InterruptedException e) {}
        };

        // schedulerを定義する


        System.out.print("開始:");

        // t1を実行直後3秒後に実行する


        // shutdown()を5秒後に実行する


    }

    static int printStartDiff() {
        long elapsedMillis = System.currentTimeMillis() - startTime;
        elapsedMillis /= 1000;
        return (int) elapsedMillis;
    }
}

package jp.paiza.thread;

import java.time.*;
import java.time.format.*;
import java.util.concurrent.*;

public class TEST {

    private static long startTime = System.currentTimeMillis();

    public static void main(String... args) {
        Runnable t1 = () -> {
            try {
                System.out.println(printStartDiff() + "秒");
                TimeUnit.SECONDS.sleep(2);
            } catch (InterruptedException e) {}
        };

        // schedulerを定義する


        System.out.print("開始:");

        // t1を実行直後3秒後に実行する


        // shutdown()を5秒後に実行する


    }

    static int printStartDiff() {
        long elapsedMillis = System.currentTimeMillis() - startTime;
        elapsedMillis /= 1000;
        return (int) elapsedMillis;
    }
}

package jp.paiza.thread;

import java.time.*;
import java.time.format.*;
import java.util.concurrent.*;

public class TEST {

    private static long startTime = System.currentTimeMillis();

    public static void main(String... args) {
        Runnable t1 = () -> {
            try {
                System.out.println(printStartDiff() + "秒");
                TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedException e) {}
        };

        // schedulerを定義する


        System.out.print("開始:");

        // t1を即時実行後、2秒間隔で実行する


        // shutdown()を5秒後に実行する

    }

    static int printStartDiff() {
        long elapsedMillis = System.currentTimeMillis() - startTime;
        elapsedMillis /= 1000;
        return (int) elapsedMillis;
    }
}

package jp.paiza.thread;

import java.time.*;
import java.time.format.*;
import java.util.concurrent.*;

public class TEST {

    private static long startTime = System.currentTimeMillis();

    public static void main(String... args) {
        Runnable t1 = () -> {
            try {
                System.out.println(printStartDiff() + "秒");
                TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedException e) {}
        };

        // schedulerを定義する


        System.out.print("開始:");

        // t1を即時実行後、2秒間隔で実行する


        // shutdown()を5秒後に実行する

    }

    static int printStartDiff() {
        long elapsedMillis = System.currentTimeMillis() - startTime;
        elapsedMillis /= 1000;
        return (int) elapsedMillis;
    }
}

package jp.paiza.thread;

import java.time.*;
import java.time.format.*;
import java.util.concurrent.*;

public class TEST {

    private static long startTime = System.currentTimeMillis();

    public static void main(String... args) {
        Runnable t1 = () -> {
            try {
                System.out.println(printStartDiff() + "秒");
                TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedException e) {}
        };

        // schedulerを定義する


        System.out.print("開始:");
        
        // 実行に1秒かかるt1を即時実行後、2秒間隔で実行する


        // 5秒後にshutdown()を実行する
        

    }

    static int printStartDiff() {
        long elapsedMillis = System.currentTimeMillis() - startTime;
        elapsedMillis /= 1000;
        return (int) elapsedMillis;
    }
}

package jp.paiza.thread;

import java.time.*;
import java.time.format.*;
import java.util.concurrent.*;

public class TEST {

    private static long startTime = System.currentTimeMillis();

    public static void main(String... args) {
        Runnable t1 = () -> {
            try {
                System.out.println(printStartDiff() + "秒");
                TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedException e) {}
        };

        // schedulerを定義する


        System.out.print("開始:");
        
        // 実行に1秒かかるt1を即時実行後、2秒間隔で実行する


        // 5秒後にshutdown()を実行する
        

    }

    static int printStartDiff() {
        long elapsedMillis = System.currentTimeMillis() - startTime;
        elapsedMillis /= 1000;
        return (int) elapsedMillis;
    }
}

この動画を見るには

paiza会員登録のうえ

有料会員登録が必要です

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

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

newSingleThreadScheduledExecutorのscheduleメソッドを用いて、t1を実行直後と3秒後に実行されるようにしてください。また、5秒後にshutdown()されるようにしてください。

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

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

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

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

期待する出力値

開始:0秒
3秒

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

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

newSingleThreadScheduledExecutorのscheduleAtFixedRateメソッドを用いて、t1を即時実行後、2秒間隔で実行されるようにしてください。また、5秒後にshutdown()されるようにしてください。

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

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

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

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

期待する出力値

開始:0秒
2秒
4秒

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

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

newSingleThreadScheduledExecutorのscheduleWithFixedDelayメソッドを用いて、実行に1秒かかるt1を即時実行後、2秒間隔で実行されるようにしてください。また、5秒後にshutdown()されるようにしてください。

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

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

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

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

期待する出力値

開始:0秒
2秒
4秒

Tips

動画へ戻る

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

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

詳しい説明を読む

＃04:Executorフレームワーク3（ScheduledExecutorService）

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

PaizaCloud

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

PaizaCloud
https://paiza.cloud/ja/

API

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

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

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

列挙型クラスTimeUnit
https://docs.oracle.com/javase/jp/17/docs/api/java.base/java/util/concurrent/TimeUnit.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
schedule(Runnable, long, TimeUnit)

package jp.paiza.thread;

import java.time.*;
import java.time.format.*;
import java.util.concurrent.*;

public class A {

    public static void main(String... args) {
        
        Runnable t1 = () -> { 
            try {
                println("-");
                TimeUnit.SECONDS.sleep(2); 
            } catch (InterruptedException e) {}
        };
        
        Callable<Boolean> t2 = () -> {
            println("-");
            return true;
        };
        
        var scheduler = Executors.newSingleThreadScheduledExecutor();
        println("start");
        scheduler.schedule(t1, 5, TimeUnit.SECONDS);
        scheduler.schedule(() -> scheduler.shutdown(), 15, TimeUnit.SECONDS);
    }
    
    /**
     * 時間を付与して文字列を出力
     */
    static void println(Object msg) {
        System.out.println(
            LocalDateTime.now().format(
                DateTimeFormatter.ofPattern("mm:ss:n")) + " " + msg);
    }
}

scheduleAtFixedRate(Runnable, long, long, TimeUnit)

package jp.paiza.thread;

import java.time.*;
import java.time.format.*;
import java.util.concurrent.*;

public class A {

    public static void main(String... args) {
        
        Runnable t1 = () -> { 
            try {
                println("-");
                TimeUnit.SECONDS.sleep(2); 
            } catch (InterruptedException e) {}
        };
        
        Callable<Boolean> t2 = () -> {
            println("-");
            return true;
        };

        var scheduler = Executors.newSingleThreadScheduledExecutor();
        println("start");
        scheduler.scheduleAtFixedRate(t1, 0, 5, TimeUnit.SECONDS);
        scheduler.schedule(() -> scheduler.shutdown(), 15, TimeUnit.SECONDS);
    }
    
    /**
     * 時間を付与して文字列を出力
     */
    static void println(Object msg) {
        System.out.println(
            LocalDateTime.now().format(
                DateTimeFormatter.ofPattern("mm:ss:n")) + " " + msg);
    }
}

scheduleWithFixedDelay(Runnable, long, long, TimeUnit)

package jp.paiza.thread;

import java.time.*;
import java.time.format.*;
import java.util.concurrent.*;

public class A {

    public static void main(String... args) {
        
        Runnable t1 = () -> { 
            try {
                println("-");
                TimeUnit.SECONDS.sleep(2); 
            } catch (InterruptedException e) {}
        };
        
        Callable<Boolean> t2 = () -> {
            println("-");
            return true;
        };

        var scheduler = Executors.newSingleThreadScheduledExecutor();
        println("start");
        scheduler.scheduleWithFixedDelay(t1, 0, 5, TimeUnit.SECONDS);
        scheduler.schedule(() -> scheduler.shutdown(), 15, TimeUnit.SECONDS);
    }
    
    /**
     * 時間を付与して文字列を出力
     */
    static void println(Object msg) {
        System.out.println(
            LocalDateTime.now().format(
                DateTimeFormatter.ofPattern("mm:ss:n")) + " " + msg);
    }
}

schedule(Callable, long, TimeUnit)

package jp.paiza.thread;

import java.time.*;
import java.time.format.*;
import java.util.concurrent.*;

public class A {

    public static void main(String... args) {
        
        Runnable t1 = () -> { 
            try {
                println("-");
                TimeUnit.SECONDS.sleep(2); 
            } catch (InterruptedException e) {}
        };
        
        Callable<Boolean> t2 = () -> {
            println("-");
            return true;
        };

        var scheduler = Executors.newSingleThreadScheduledExecutor();
        println("start");
        var result = scheduler.schedule(t2, 5, TimeUnit.SECONDS);
        scheduler.schedule(() -> scheduler.shutdown(), 15, TimeUnit.SECONDS);
        
        try {
            println(result.get());
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        }
    }
    
    /**
     * 時間を付与して文字列を出力
     */
    static void println(Object msg) {
        System.out.println(
            LocalDateTime.now().format(
                DateTimeFormatter.ofPattern("mm:ss:n")) + " " + msg);
    }
}

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

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

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

期待する出力値

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

期待する出力値

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

期待する出力値

＃04:Executorフレームワーク3（ScheduledExecutorService）

PaizaCloud

関連するコンテンツ

API

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

完成コード