Java多線程模擬銀行系統(tǒng)存錢問題詳解

更新時(shí)間：2022年09月23日 08:24:48 作者：小虛竹and掘金

本文將利用Java多線程模擬一個(gè)簡(jiǎn)單的銀行系統(tǒng)，使用兩個(gè)不同的線程向同一個(gè)賬戶存錢。文中的示例代碼講解詳細(xì)，感興趣的可以了解一下

一、題目描述

題目：模擬一個(gè)簡(jiǎn)單的銀行系統(tǒng)，使用兩個(gè)不同的線程向同一個(gè)賬戶存錢。

實(shí)現(xiàn)：使用特殊域變量volatile實(shí)現(xiàn)同步。

二、解題思路

創(chuàng)建一個(gè)類：SynchronizedBankFrame，繼承JFrame類

寫一個(gè)內(nèi)部類Bank

定義一個(gè)account變量，來表示賬戶。
deposit():一個(gè)存錢的方法
getAccount()：顯示賬戶余額的方法。

寫一個(gè)內(nèi)部類Transfer，實(shí)現(xiàn)Runnable接口

在run方法中實(shí)現(xiàn)向賬戶存錢的功能。

volatile關(guān)鍵字為變量訪問提供了一種免鎖機(jī)制。使用volatile關(guān)鍵字修飾變量，每次使用該變量就要重新計(jì)算，而不是使用寄存器中的值。

volatile不會(huì)提供原子操作，也不能用來修飾final類型的變量。

三、代碼詳解

SynchronizedBankFrame

package com.xiaoxuzhu;
import java.awt.BorderLayout;
import java.awt.EventQueue;

import javax.swing.JFrame;
import javax.swing.JPanel;
import javax.swing.border.EmptyBorder;
import javax.swing.JButton;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import java.awt.event.ActionListener;
import java.awt.event.ActionEvent;
import java.awt.GridLayout;
import javax.swing.JLabel;
import javax.swing.SwingConstants;
import java.awt.Font;
import javax.swing.UIManager;
/**
 * Description:
 *
 * @author xiaoxuzhu
 * @version 1.0
 *
 * <pre>
 * 修改記錄:
 * 修改后版本	        修改人		修改日期			修改內(nèi)容
 * 2022/5/14.1	    xiaoxuzhu		2022/5/14		    Create
 * </pre>
 * @date 2022/5/14
 */
public class SynchronizedBankFrame extends JFrame {

    /**
     *
     */
    private static final long serialVersionUID = 2671056183299397274L;
    private JPanel contentPane;
    private JTextArea thread1TextArea;
    private JTextArea thread2TextArea;

    /**
     * Launch the application.
     */
    public static void main(String[] args) {
        try {
            UIManager.setLookAndFeel("com.sun.java.swing.plaf.nimbus.NimbusLookAndFeel");
        } catch (Throwable e) {
            e.printStackTrace();
        }
        EventQueue.invokeLater(new Runnable() {
            public void run() {
                try {
                    SynchronizedBankFrame frame = new SynchronizedBankFrame();
                    frame.setVisible(true);
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        });
    }

    /**
     * Create the frame.
     */
    public SynchronizedBankFrame() {
        setTitle("使用volatile實(shí)現(xiàn)線程同步");
        setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
        setBounds(100, 100, 450, 300);
        contentPane = new JPanel();
        contentPane.setBorder(new EmptyBorder(5, 5, 5, 5));
        setContentPane(contentPane);
        contentPane.setLayout(new BorderLayout(0, 0));

        JPanel buttonPanel = new JPanel();
        contentPane.add(buttonPanel, BorderLayout.SOUTH);

        JButton startButton = new JButton("開始存錢");
        startButton.setFont(new Font("微軟雅黑", Font.PLAIN, 16));
        startButton.addActionListener(new ActionListener() {
            public void actionPerformed(ActionEvent arg0) {
                do_button_actionPerformed(arg0);
            }
        });
        buttonPanel.add(startButton);

        JPanel processPanel = new JPanel();
        contentPane.add(processPanel, BorderLayout.CENTER);
        processPanel.setLayout(new GridLayout(1, 2, 5, 5));

        JPanel thread1Panel = new JPanel();
        processPanel.add(thread1Panel);
        thread1Panel.setLayout(new BorderLayout(0, 0));

        JLabel thread1Label = new JLabel("一號(hào)線程");
        thread1Label.setFont(new Font("微軟雅黑", Font.PLAIN, 16));
        thread1Label.setHorizontalAlignment(SwingConstants.CENTER);
        thread1Panel.add(thread1Label, BorderLayout.NORTH);

        JScrollPane thread1ScrollPane = new JScrollPane();
        thread1Panel.add(thread1ScrollPane, BorderLayout.CENTER);

        thread1TextArea = new JTextArea();
        thread1TextArea.setFont(new Font("微軟雅黑", Font.PLAIN, 16));
        thread1ScrollPane.setViewportView(thread1TextArea);

        JPanel thread2Panel = new JPanel();
        processPanel.add(thread2Panel);
        thread2Panel.setLayout(new BorderLayout(0, 0));

        JLabel thread2Label = new JLabel("二號(hào)線程");
        thread2Label.setFont(new Font("微軟雅黑", Font.PLAIN, 16));
        thread2Label.setHorizontalAlignment(SwingConstants.CENTER);
        thread2Panel.add(thread2Label, BorderLayout.NORTH);

        JScrollPane thread2ScrollPane = new JScrollPane();
        thread2Panel.add(thread2ScrollPane, BorderLayout.CENTER);

        thread2TextArea = new JTextArea();
        thread2TextArea.setFont(new Font("微軟雅黑", Font.PLAIN, 16));
        thread2ScrollPane.setViewportView(thread2TextArea);
    }

    protected void do_button_actionPerformed(ActionEvent arg0) {
        Bank bank = new Bank();
        Thread thread1 = new Thread(new Transfer(bank, thread1TextArea));
        thread1.start();
        Thread thread2 = new Thread(new Transfer(bank, thread2TextArea));
        thread2.start();
    }

    private class Transfer implements Runnable {

        private Bank bank;
        private JTextArea textArea;

        public Transfer(Bank bank, JTextArea textArea) {
            this.bank = bank;
            this.textArea = textArea;
        }

        public void run() {
            for (int i = 0; i < 10; i++) {
                bank.deposit(10);
                String text = textArea.getText();
                textArea.setText(text + "賬戶的余額是：" + bank.getAccount() + "\n");
            }
        }
    }

    private class Bank {
        private volatile int account = 100;// 將域變量用volatile修飾

        public void deposit(int money) {// 向賬戶中存錢
            account += money;
        }

        public int getAccount() {// 獲得賬戶余額
            return account;
        }
    }

}

多學(xué)一個(gè)知識(shí)點(diǎn)

每個(gè)線程是存在緩存內(nèi)存的。且緩存內(nèi)存是對(duì)其他線程不可見的。這就是內(nèi)存不可見問題。

來驗(yàn)證下

package com.xiaoxuzhu;

/**
 * Description: 證明線程是存在緩存內(nèi)存的
 *
 * @author xiaoxuzhu
 * @version 1.0
 *
 * <pre>
 * 修改記錄:
 * 修改后版本	        修改人		修改日期			修改內(nèi)容
 * 2022/5/14.1	    xiaoxuzhu		2022/5/14		    Create
 * </pre>
 * @date 2022/5/14
 */
public class VolatileDemo {


    public static void main(String[] args) {
        ThreadDemo threadDemo = new ThreadDemo();
        //啟動(dòng)線程  改值
        new Thread(threadDemo).start();

        while (true){
            if(threadDemo.isFlag()){
                System.out.println("主線程讀到的flag是true");
                break;
            }
        }
    }

    static class  ThreadDemo implements Runnable{
        private boolean flag = false;

        public boolean isFlag() {
            return flag;
        }

        public void setFlag(boolean flag) {
            this.flag = flag;
        }

        @Override
        public void run() {
            try {
                Thread.sleep(200);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            flag = true;
            System.out.println("flag 線程執(zhí)行改為："+isFlag());
        }
    }
}

主線程得到的是false，新線程已經(jīng)把值修改為true了。證實(shí)每個(gè)線程是存在緩存內(nèi)存的