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

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

public class Main {
    public static void main(String... args) {
        
        var m = new LinkedHashMap<Integer, Integer>();
        m.put(1, 10);
        m.put(2, 20);
        m.put(3, 30);

        new Thread(() -> {
            for (var p : m.entrySet()) {
                System.out.println(p.getKey() + ":" + p.getValue());
                try {
                    TimeUnit.MILLISECONDS.sleep(500); 
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }).start();
        
        try {
            TimeUnit.MILLISECONDS.sleep(400); 
        } catch (InterruptedException e) {
        }
        
        System.out.println("remove");
        m.remove(3);
    }
}

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

public class Main {
    public static void main(String... args) {
        
        var m = new LinkedHashMap<Integer, Integer>();
        m.put(1, 10);
        m.put(2, 20);
        m.put(3, 30);

        new Thread(() -> {
            for (var p : m.entrySet()) {
                System.out.println(p.getKey() + ":" + p.getValue());
                try {
                    TimeUnit.MILLISECONDS.sleep(500); 
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }).start();
        
        try {
            TimeUnit.MILLISECONDS.sleep(400); 
        } catch (InterruptedException e) {
        }
        
        System.out.println("remove");
        m.remove(3);
    }
}

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

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

        // ConcurrentHashMapに変更する
        var m = new LinkedHashMap<Integer, Integer>();

        Scanner sc = new Scanner(System.in);
        final int N = sc.nextInt();
        int[] numArray1 = new int[N];
        int[] numArray2 = new int[N];
        for(int i = 0; i < N; i++) {
            numArray1[i] = sc.nextInt();
            numArray2[i] = sc.nextInt();
        }
        
        final int sleepTime = sc.nextInt();
        
        for (int i=0; i < N; i++) {
            m.put(numArray1[i], numArray2[i]);
        }

        new Thread(() -> {
            for (var p : m.entrySet()) {
                System.out.println(p.getKey() + ":" + p.getValue());
                try {
                    TimeUnit.MILLISECONDS.sleep(150); 
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }).start();

        try {
            TimeUnit.MILLISECONDS.sleep(sleepTime); 
        } catch (InterruptedException e) {
        }

        System.out.println("remove");
        m.remove(3);
    }
}

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

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

        // ConcurrentHashMapに変更する
        var m = new LinkedHashMap<Integer, Integer>();

        Scanner sc = new Scanner(System.in);
        final int N = sc.nextInt();
        int[] numArray1 = new int[N];
        int[] numArray2 = new int[N];
        for(int i = 0; i < N; i++) {
            numArray1[i] = sc.nextInt();
            numArray2[i] = sc.nextInt();
        }
        
        final int sleepTime = sc.nextInt();
        
        for (int i=0; i < N; i++) {
            m.put(numArray1[i], numArray2[i]);
        }

        new Thread(() -> {
            for (var p : m.entrySet()) {
                System.out.println(p.getKey() + ":" + p.getValue());
                try {
                    TimeUnit.MILLISECONDS.sleep(150); 
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }).start();

        try {
            TimeUnit.MILLISECONDS.sleep(sleepTime); 
        } catch (InterruptedException e) {
        }

        System.out.println("remove");
        m.remove(3);
    }
}

この動画を見るには

paiza会員登録のうえ

有料会員登録が必要です

演習1

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

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

現在、右側のコードはマルチスレッド環境でスレッドセーフではない操作を実行しており、実行タイミングによってはConcurrentModificationExceptionというエラーが出力される可能性があります。また、標準入力として配列の要素数、各要素の数値(Mapのため2つずつ)、削除するまでsleep()する秒数が与えられています。ConcurrentHashMapを使用してスレッドセーフなHashMapを実装してください。

入力される値

4
2
3
7
1
1
4
8
1
250

標準入力からの値取得方法はこちらをご確認ください

期待する出力値

1:4
2:3
remove
7:1
8:1

Tips

動画へ戻る

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

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

詳しい説明を読む

＃09:並行コレクション4（Map）

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

API

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

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

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

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

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

完成コード

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

public class Main {
    public static void main(String... args) {
        
        var m = new ConcurrentHashMap<Integer, Integer>();
        m.put(1, 10);
        m.put(2, 20);
        m.put(3, 30);

        new Thread(() -> {
            for (var p : m.entrySet()) {
                System.out.println(p.getKey() + ":" + p.getValue());
                try {
                    TimeUnit.MILLISECONDS.sleep(500); 
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }).start();
        
        try {
            TimeUnit.MILLISECONDS.sleep(400); 
        } catch (InterruptedException e) {
        }
        
        System.out.println("remove");
        m.remove(3);
    }
}

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

ログインすると採点できます

コードの実行

有料会員になるとエンジニアに質問ができます

出力タイプ：

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

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

入力される値

期待する出力値

＃09:並行コレクション4（Map）

関連するコンテンツ

API

完成コード