新・Java入門編44:並行コレクション5（Queue）

package jp.paiza.thread;

import java.util.*;
import java.util.concurrent.*;

public class TEST {

    public static void main(String... args) {

        var q = new ArrayBlockingQueue<Integer>(3);

        var t1 = new Thread(() -> {
            try {
                for (int i = 0; i < 10; i++) {
                    try {
                        Thread.sleep(7);
                    } catch (InterruptedException e) {}
                    System.out.println(q);
                    // キューが満杯だとブロック
                    q.put(i);
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });

        var t2 = new Thread(() -> {
            try {
                for (int i = 0; i < 10; i++) {
                    try {
                        Thread.sleep(9);
                    } catch (InterruptedException e) {}
                    System.out.println(q);
                    // キューが空だとブロック
                    q.take();
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });

        // コードを追記する
        
    }
}

package jp.paiza.thread;

import java.util.*;
import java.util.concurrent.*;

public class TEST {

    public static void main(String... args) {

        var q = new ArrayBlockingQueue<Integer>(3);

        var t1 = new Thread(() -> {
            try {
                for (int i = 0; i < 10; i++) {
                    try {
                        Thread.sleep(7);
                    } catch (InterruptedException e) {}
                    System.out.println(q);
                    // キューが満杯だとブロック
                    q.put(i);
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });

        var t2 = new Thread(() -> {
            try {
                for (int i = 0; i < 10; i++) {
                    try {
                        Thread.sleep(9);
                    } catch (InterruptedException e) {}
                    System.out.println(q);
                    // キューが空だとブロック
                    q.take();
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });

        // コードを追記する
        
    }
}

この動画を見るには

paiza会員登録のうえ

有料会員登録が必要です

演習1

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

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

現在、ArrayBlockingQueueを使用して2つのThreadでサイズが3のキューに0から9までの値を順に追加、取得しようとしています。コードを追記して、正しく動作するようにしてください。

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

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

期待する出力値

[]
[0]
[]
[1]
[]
[2]
[]
[3]
[3, 4]
[4]
[4, 5]
[5]
[5, 6]
[6]
[6, 7]
[7]
[7, 8]
[7, 8, 9]
[8, 9]
[9]

Tips

動画へ戻る

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

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

詳しい説明を読む

＃10:並行コレクション5（Queue）

このチャプターでは、並行コレクションのQueueについて学習します。

PaizaCloud

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

PaizaCloud
https://paiza.cloud/ja/

API

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

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

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

クラスConcurrentModificationException
https://docs.oracle.com/javase/jp/17/docs/api/java.base/java/util/ConcurrentModificationException.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.*;
import java.util.concurrent.*;

public class A {

    public static void main(String... args) {
        
        var q = new ArrayBlockingQueue<Integer>(3);

        var t1 = new Thread(() -> {
            try {
                for (int i = 0; i < 10; i++) {
                    System.out.println(i + ":Produced: " + q.size());
                    // キューが満杯だとブロック
                    q.put(i);
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });

        var t2 = new Thread(() -> {
            try {
                for (int i = 0; i < 10; i++) {
                    System.out.println(i + ":Consumed: " + q.size());
                    // キューが空だとブロック
                    q.take();
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });

        t1.start();
        t2.start();

        try {
            t1.join();
            t2.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

プログラミング学習 > Java > 新・Java入門編 > 新・Java入門編44: 並行・並列処理についてさらに学習しよう > 並行コレクション5（Queue）

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