新・Java入門編44:アトミック変数（Atomic Variables）

package jp.paiza.thread;

import java.util.stream.*;
import java.util.concurrent.atomic.*;

public class TEST {

    static class Bank {

        /** 残高 */
        // int型をアトミックインテジャー型に変える
        private int balance = 12345;

        /** 入金 */
        // addAndGetを用いて入出金を行う
        void deposit(int amount) {
            balance += amount;
        }

        /** 出金 */
        // addAndGetを用いて入出金を行う
        void withdraw(int amount) {
            balance -= amount;
        }

        /** 残高照会 */
        int getBalance() {
            return balance;
        }
    }

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

        final var bank = new Bank();

        var t1 = new Thread(() -> IntStream.range(0, 100000).forEach(i -> bank.deposit(14)));
        var t2 = new Thread(() -> IntStream.range(0, 100000).forEach(i -> bank.withdraw(8)));

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

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

        System.out.println(bank.getBalance());
    }
}

package jp.paiza.thread;

import java.util.stream.*;
import java.util.concurrent.atomic.*;

public class TEST {

    static class Bank {

        /** 残高 */
        // int型をアトミックインテジャー型に変える
        private int balance = 12345;

        /** 入金 */
        // addAndGetを用いて入出金を行う
        void deposit(int amount) {
            balance += amount;
        }

        /** 出金 */
        // addAndGetを用いて入出金を行う
        void withdraw(int amount) {
            balance -= amount;
        }

        /** 残高照会 */
        int getBalance() {
            return balance;
        }
    }

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

        final var bank = new Bank();

        var t1 = new Thread(() -> IntStream.range(0, 100000).forEach(i -> bank.deposit(14)));
        var t2 = new Thread(() -> IntStream.range(0, 100000).forEach(i -> bank.withdraw(8)));

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

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

        System.out.println(bank.getBalance());
    }
}

この動画を見るには

paiza会員登録のうえ

有料会員登録が必要です

演習1

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

演習課題「アトミック変数を使ってみよう」

現在、右側の演習環境には銀行口座への入出金をおこなうプログラムがあります。しかし、このコードを何度か実行すると、想定しない値が出力されることがあります。ここで、アトミック変数を用いて、銀行口座への入出金が正しく実行されるようにしてください。

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

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

期待する出力値

612345

Tips

動画へ戻る

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

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

詳しい説明を読む

＃05:アトミック変数（Atomic Variables）

このチャプターでは、アトミック変数について学習します。

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.stream.*;
import java.util.concurrent.atomic.*;

public class A {

    /** 銀行 */
    static class Bank {
        
        /** 残高 */
        private AtomicInteger balance = new AtomicInteger(10000);
    
        /** 入金 */
        void deposit(int amount) {
            balance.addAndGet(amount);
        }
    
        /** 出金 */
        void withdraw(int amount) {
            balance.addAndGet(-amount);
        }
    
        /** 残高照会 */
        int getBalance() {
            return balance.get();
        }
    }
    
    public static void main(String... args) {

        final var bank = new Bank();

        var t1 = new Thread(() -> IntStream.range(0, 100000).forEach(i -> bank.deposit(10)));
        var t2 = new Thread(() -> IntStream.range(0, 100000).forEach(i -> bank.withdraw(10)));

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

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

        System.out.println(bank.getBalance());
    }
}

プログラミング学習 > Java > 新・Java入門編 > 新・Java入門編44: 並行・並列処理についてさらに学習しよう > アトミック変数（Atomic Variables）

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

演習課題「アトミック変数を使ってみよう」

期待する出力値

＃05:アトミック変数（Atomic Variables）

PaizaCloud

関連するコンテンツ

API

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

完成コード