栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

【Java】 线程同步synchronized

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

【Java】 线程同步synchronized

线程同步synchronized 1.线程同步机制

在多线程编程,一些敏感数据不允许被多个线程同时访问,此时就使用同步访问技术,保证数据在任何同一时刻,最多有一个线程访问,以保证数据的完整性。即当一个线程在对内进行操作时,其他线程都不可以对这个内存地址进行操作,直到该线程完成操作,其他线程才能对该内存地址进行操作。

2.同步具体方法 2.1 同步代码块
synchronized(对象) {					//得到对象的锁,才能操作同步代码
    需要被同步代码;
}

2.2 同步方法
public synchronized void m(String name){
     需要被同步的代码;
}

3.实际应用 3.1 问题描述

用线程同步的两种方法解决售票超卖问题

3.2 方法一:同步代码块 3.2.1 代码编写
public class SellTicketThread01 {
    public static void main(String[] args) {
        
        System.out.println("====使用继承Thread类方式来售票====");
        System.out.println("====使用“同步代码块”方式来解决售票超卖问题====");
        SellTicket01 sellTicket01 = new SellTicket01();
        SellTicket01 sellTicket02 = new SellTicket01();
        SellTicket01 sellTicket03 = new SellTicket01();
        sellTicket01.start();
        sellTicket02.start();
        sellTicket03.start();
    }
}
class SellTicket01 extends Thread{
    private boolean bool = true;
    private static int ticketNum = 10;//让多个线程共享ticketNum
    public void sell() {
        synchronized (SellTicket01.class){   //要求多个线程的锁对象为同一个,此处不能用this,用this锁不住
            if (ticketNum <= 0) {
                System.out.println("售票结束...");
                bool = false;
                return;
            }
            try {
                Thread.sleep(100);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("窗口" + Thread.currentThread().getName()
                    + "售出一张票" + "剩余票数=" + (--ticketNum));
        }
    }
    @Override
    public void run() {
        while(bool){
           sell();
        }
    }
}
3.2.2 运行结果

3.3 方法二:同步方法 3.3.1 代码编写
public class SellTicketThread02 {
    public static void main(String[] args) {
        
        System.out.println("====使用实现Runnable接口方式来售票====");
        System.out.println("====使用“同步方法”方式来解决售票超卖问题====");
        SellTicket02 sellTicket021 = new SellTicket02();
        Thread thread01 = new Thread(sellTicket021);
        Thread thread02 = new Thread(sellTicket021);
        Thread thread03 = new Thread(sellTicket021);
        thread01.start();
        thread02.start();
        thread03.start();
    }
}
class SellTicket02 implements Runnable{
    private boolean bool = true;
    private static int ticketNum = 100;//让多个线程共享ticketNum
    public synchronized void sell(){   //使用“同步方法”方式来解决售票超卖问题
        if(ticketNum<=0){
            System.out.println("售票结束...");
            bool = false;
            return;
        }
        try {
            Thread.sleep(100);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("窗口"+Thread.currentThread().getName()
                +"售出一张票"+"剩余票数="+(--ticketNum));
    }
    @Override
    public void run() {
        while(bool){
            sell();
        }
    }
}
3.3.2 运行结果

4.总结

关键字synchronized来与对象的互斥锁联系,每个对象都对应一个可称为“互斥锁”的标记。
(1) 同步方法如果没有使用satic修饰,默认锁对象为this;
(2) 同步方法如果使用static修饰,默认锁对象为当前类.class
(3) 要求多个线程的锁对象为同一个,即用当前类.class,不能用this。

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/830832.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号