文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

java中线程安全问题举例分析

2023-06-21 21:14

关注

这篇文章主要讲解了“java中线程安全问题举例分析”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“java中线程安全问题举例分析”吧!

一、什么时候数据在多线程并发的环境下会存在安全问题?

三个条件:

满足以上3个条件之后,就会存在线程安全问题。

二、怎么解决线程安全问题?

        线程排队执行。(不能并发)。用排队执行解决线程安全问题。这种机制被称为:线程同步机制。

java中线程安全问题举例分析

三、银行 取钱/存钱 案例

Account 类

package ThreadSafa;  public class Account {    // 账号    private String actno;    // 余额    private double balance;     public Account() {    }     public Account(String actno, double balance) {        this.actno = actno;        this.balance = balance;    }     public String getActno() {        return actno;    }     public void setActno(String actno) {        this.actno = actno;    }     public double getBalance() {        return balance;    }     public void setBalance(double balance) {        this.balance = balance;    }     //取款方法    public void withdraw(double money) {        // 取款之前的余额        double before = this.getBalance();        // 取款之后的余额        double after = before - money;        // 更新余额        try {            //模拟网络延时 更新余额不及时 百分百会出问题            Thread.sleep(1 * 1000);        } catch (InterruptedException e) {            e.printStackTrace();        }        this.setBalance(after);    }}

AccountThread 类

package ThreadSafa; public class AccountThread extends Thread {    // 两个线程必须共享同一个账户对象。    private Account act;     //通过构造方法传递过来账户对象      public AccountThread(Account act) {        this.act = act;    }     @Override    public void run() {        double money = 5000;        //取款        act.withdraw(5000);         System.out.println(Thread.currentThread().getName() + "账户" + act.getActno() + "取款成功,余额" + act.getBalance());    }}

Test 类

package ThreadSafa; public class Test {    public static void main(String[] args) {        // 创建账户对象        Account act = new Account("act-001", 10000);        //创建两个线程        Thread t1 = new AccountThread(act);        Thread t2 = new AccountThread(act);        //设置name        t1.setName("t1");        t2.setName("t2");        //启动线程        t1.start();        t2.start();    }}

 运行问题

java中线程安全问题举例分析

 解决方法  修改 Account 类  中的 withdraw 方法

package ThreadSafa;  public class Account {    // 账号    private String actno;    // 余额    private double balance;     public Account() {    }     public Account(String actno, double balance) {        this.actno = actno;        this.balance = balance;    }     public String getActno() {        return actno;    }     public void setActno(String actno) {        this.actno = actno;    }     public double getBalance() {        return balance;    }     public void setBalance(double balance) {        this.balance = balance;    }     //取款方法    public void withdraw(double money) {        // 以下这几行代码必须是线程排队的,不能并发        // 一个线程把这里的代码全部执行结束之后,另外一个线程才能进来                  synchronized (this) {            // 取款之前的余额            double before = this.getBalance();            // 取款之后的余额            double after = before - money;            // 更新余额            try {                //模拟网络延时 更新余额不及时 百分百会出问题                Thread.sleep(1 * 1000);            } catch (InterruptedException e) {                e.printStackTrace();            }            this.setBalance(after);        }    }}

为什么会出现线程安全问题

计算机系统资源分配的单位为进程,同一个进程中允许多个线程并发执行,并且多个线程会共享进程范围内的资源:例如内存地址。当多个线程并发访问同一个内存地址并且内存地址保存的值是可变的时候可能会发生线程安全问题,因此需要内存数据共享机制来保证线程安全问题。

对应到java服务来说,在虚拟中的共享内存地址是java的堆内存,比如以下程序中线程安全问题:

public class ThreadUnsafeDemo {    private static final ExecutorService EXECUTOR_SERVICE;    static {        EXECUTOR_SERVICE = new ThreadPoolExecutor(100, 100, 1000 * 10,                TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(100), new ThreadFactory() {            private AtomicLong atomicLong = new AtomicLong(1);            @Override            public Thread newThread(Runnable r) {                return new Thread(r, "Thread-Safe-Thread-" + atomicLong.getAndIncrement());            }        });    }    public static void main(String[] args) throws Exception {        Map<String, Integer> params = new HashMap<>();        List<Future> futureList = new ArrayList<>(100);        for (int i = 0; i < 100; i++) {            futureList.add(EXECUTOR_SERVICE.submit(new CacheOpTask(params)));        }        for (Future future : futureList) {            System.out.println("Future result:" + future.get());        }        System.out.println(params);    }    private static class CacheOpTask implements Callable<Integer> {        private Map<String, Integer> params;        CacheOpTask(Map<String, Integer> params) {            this.params = params;        }        @Override        public Integer call() {            for (int i = 0; i < 100; i++) {                int count = params.getOrDefault("count", 0);                params.put("count", ++count);            }            return params.get("count");        }    }}

创建100个task,每个task对map中的元素累加100此,程序执行结果为:

{count=9846}

而预期的正确结果为:

{count=10000}

至于出现这种问题的原因,下面会具体分析。

判断是否有线程安全性的一个原则是:

是否有多线程访问可变的共享变量

感谢各位的阅读,以上就是“java中线程安全问题举例分析”的内容了,经过本文的学习后,相信大家对java中线程安全问题举例分析这一问题有了更深刻的体会,具体使用情况还需要大家实践验证。这里是编程网,小编将为大家推送更多相关知识点的文章,欢迎关注!

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯