十一、Properties、多线程

news2024/11/15 11:12:02

Properties集合

Properties作为Map集合的使用

介绍

  • 是一个Map体系的集合类
  • Properties可以保存到流中或从流中加载
  • 属性列表中的每个键及其对应的值都是一个字符串

基本使用

public static void main(String[] args) {
    Properties prop = new Properties();
    //增
    prop.put("小龙女", "尹志平");
    prop.put("郭襄", "杨过");
    prop.put("黄蓉", "欧阳克");
    System.out.println(prop);


    //删
    //prop.remove("郭襄");
    //System.out.println(prop);

    //改
    //put --- 如果键不存在,那么就添加,如果键存在,那么就覆盖.
    prop.put("小龙女", "杨过");
    System.out.println(prop);
    //查

    //Object value = prop.get("黄蓉");
    //System.out.println(value);

    //遍历
    Set<Object> keys = prop.keySet();
    for (Object key : keys) {
        Object value = prop.get(key);
        System.out.println(key + "=" + value);
    }

    System.out.println("========================");

    //装的是所有的键值对对象.
    Set<Map.Entry<Object, Object>> entries = prop.entrySet();
    for (Map.Entry<Object, Object> entry : entries) {
        Object key = entry.getKey();
        Object value = entry.getValue();
        System.out.println(key + "=" + value);
    }

}

Properties作为Map集合的特有方法

方法名说明
Object setProperty(String key, String value)设置集合的键和值,都是String类型,底层调用 Hashtable方法 put
String getProperty(String key)使用此属性列表中指定的键搜索属性
Set stringPropertyNames()从该属性列表中返回一个不可修改的键集,其中键及其对应的值是字符串

代码

        Properties prop = new Properties();
        //1增
        prop.setProperty("小龙女", "尹志平");
        prop.setProperty("郭襄", "杨过");
        prop.setProperty("黄蓉", "欧阳克");

        //2获取
        System.out.println(prop.getProperty("小龙女"));
        System.out.println(prop.getProperty("郭襄"));
        System.out.println(prop.getProperty("黄蓉"));
        System.out.println(prop.getProperty("周芷若"));
        //参数2 是当key找不到时,返回指定的默认值
        System.out.println(prop.getProperty("神雕", "我叫默认值"));


        //3获取所有的key的set集合
        Set<String> keys = prop.stringPropertyNames();
        //遍历所有的key 获取对应的值
        for (String key : keys) {
            System.out.println(key + "----" + prop.getProperty(key));
        }

Properties和IO流相结合的方法

方法名说明
void load(Reader reader)从输入字符流读取属性列表(键和元素对)
void store(Writer writer, String comments)将此属性列表(键和元素对)写入此 Properties表中,以适合使用 load(Reader)方法的格式写入输出字符流

代码1 Properties结合BufferedWriter存数据

  • 保存的文件名字 一般以.properties为后缀
public class Demo03 {
    public static void main(String[] args) throws IOException {


        Properties prop = new Properties();

        prop.setProperty("001", "xiaoming");
        prop.setProperty("002", "xiaohong");
        prop.setProperty("003", "xiaolan");

        prop.setProperty("小龙女", "尹志平");
        prop.setProperty("郭襄", "杨过");
        prop.setProperty("黄蓉", "欧阳克");


        BufferedWriter writer = new BufferedWriter(new FileWriter("a.properties"));

        //prop.store(writer, null);
        //保存数据到文件  参1是帮助写数据的流对象  参数2是保存的数据的说明 会写到文件里,可以不写 传null
        prop.store(writer, "保存的数据hello");


    }
}

代码1 Properties结合BufferedReader加载数据

Properties prop = new Properties();
BufferedReader br = new BufferedReader(new FileReader("a.txt"));

//从流中读取数据到集合
prop.load(br);

System.out.println(prop);

System.out.println(prop.getProperty("小龙女"));
System.out.println(prop.getProperty("郭襄"));
System.out.println(prop.getProperty("黄蓉"));

Properties集合练习(课下完成)

需求

  • 在Properties文件中手动写上姓名和年龄,读取到Properties集合中,将该数据封装成学生对象,写到本地文件中

在这里插入图片描述

步骤

  • 创建Properties集合,将本地文件中的数据加载到集合中
  • 获取集合中的键值对数据,封装到学生对象中
  • 创建序列化流对象,将学生对象序列化到本地文件中

代码实现

  • 学生类
public class Student {
    private String name;
    private int age;

    public Student() {
    }

    public Student(String name, int age) {
        this.name = name;
        this.age = age;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public int getAge() {
        return age;
    }

    public void setAge(int age) {
        this.age = age;
    }

    @Override
    public String toString() {
        return "Student{" +
                "name='" + name + '\'' +
                ", age=" + age +
                '}';
    }
}

测试类

public class Test {

    public static void main(String[] args) throws IOException {
      	//1.创建Properties集合对象,使用字符读取缓冲流将本地文件中的数据加载到集合对象中
        
		//2.获取集合中的键值对数据,封装到学生对象中
     
		//3.创建序列化流对象,将学生对象序列化到本地文件中
    }
}

多线程(重点重点重点重点重点重点重点重点)

目标:

  • 1 线程的相关 概念
  • 2 线程创建和启动 方法1和2(掌握)
  • 3 线程创建和启动 方法3 (掌握)
  • 4 理解三种创建的区别

实现多线程方式一:继承Thread类

  • 方法介绍

    方法名说明
    void run()在线程开启后,此方法将被调用执行
    void start()使此线程开始执行,Java虚拟机会调用run方法
  • 实现步骤

    • 1定义一个类继承Thread类
    • 2在类中重写run()方法
    • 3用这个类创建对象
    • 4用对象调用start 开启线程

代码演示

注意:直接调用run方法 不会开启线程

  • 创建线程的类
public class MyThread extends Thread {
    @Override
    public void run() {
        super.run();
        for (int i = 0; i < 100; i++) {
            System.out.println("我唱歌" + i);
        }
    }
}
  • 测试类中使用线程
public class Demo02 {
    public static void main(String[] args) {
        // 1 写一个类继承Thread
        //2 重写run方法
        //3 用这个类创建对象
        MyThread t1 = new MyThread();
        //4 用对象调用start 开启线程
        t1.start();

	 //再次创建一个线程
        MyThread t2 = new MyThread();
        //开启线程
        t2.start();
    }
}

Thread中的方法

构造方法:

  • Thread():空参数的构造方法。
  • Thread(String name):一个参数是字符串的构造方法,参数表示线程名字。

其它方法

  • String getName():获取线程名字。
  • void setName(String name):设置线程名字。
  • static Thread currentThread():获取当前正在执行的线程对象。
  • static void sleep(long millis):线程休眠,参数是休眠的毫秒值。

代码

  • 实现两个子线程一个唱歌一个跳舞,主线程打篮球 如下:

Thread子类的代码

  • 两个子类,一个唱歌,一个跳舞, 都写了空参 和有参构造,有参构造里可以传入一个字符串给线程命名
  • 在run中,调用了getName方法获取了线程的名字
public class MyThread extends Thread {

    public MyThread() {
    }

    public MyThread(String name) {
        super(name);
    }

    @Override
    public void run() {
        super.run();
        for (int i = 0; i < 100; i++) {
            System.out.println("我唱歌" + i+"---"+getName());

        }
    }
}

class MyThread2 extends Thread {
    public MyThread2() {
    }

    public MyThread2(String name) {
        super(name);
    }

    @Override
    public void run() {
        super.run();
        for (int i = 0; i < 100; i++) {
            System.out.println("我跳舞" + i+"---"+getName());
        }
    }
}

测试代码

  • 创建Thread对象的时候,传入了线程的名字 sing和dance
  • 主线程for循环中打篮球,通过Thread.currentThread() 获取当前线程对象 然后getName()获取线程的名字
public class Demo05 {
    public static void main(String[] args) {
        // 1 写一个类继承Thread
        //2 重写run方法
        //3 用这个类创建对象
        MyThread t1 = new MyThread("sing");
        //4 用对象调用start 开启线程
        t1.start();


        MyThread2 t2 = new MyThread2("dance");
        t2.start();


        for (int i = 0; i < 100; i++) {
            System.out.println("我打篮球" + i);
            //Thread.currentThread() 获取当前线程对象 然后getName()获取线程的名字
            //这里是主线程 名字是main
            System.out.println(Thread.currentThread().getName());
        }
    }
}

线程流程图

在这里插入图片描述

实现多线程方式二:实现Runnable接口

Thread构造方法

方法名说明
Thread(Runnable target)分配一个新的Thread对象
Thread(Runnable target, String name)分配一个新的Thread对象

实现步骤

  • 定义一个类MyRunnable实现Runnable接口
  • 在MyRunnable类中重写run()方法
  • 创建MyRunnable类的对象
  • 创建Thread类的对象,把MyRunnable对象作为构造方法的参数传入
  • 调用Thread类的对象的start方法启动线程

Runnable代码

  • 类MyRunnable实现Runnable接口,重写run()方法,
  • 方法中Thread.currentThread().getName()获取了线程的名字
public class MyRunnable implements Runnable {
    @Override
    public void run() {
        for (int i = 0; i < 100; i++) {
            System.out.println("吃肉夹馍" + i);
            System.out.println(Thread.currentThread().getName());
        }
    }
}

线程测试代码

  • 创建了三个线程
    • 1 Thread t 在创建的时候,构造方法中传入了Runnable对象
    • 2Thread t2,创建的时候使用lambda表达式传入了Runnable的实现类对象
    • 3 直接在new Thread的时候使用lambda表达式传入了Runnable的实现类对象,然后直接start开启线程
        //1创建了MyRunnable对象 里面存放了要执行的任务
        MyRunnable r = new MyRunnable();

        //2创建线程对象 把Runnable对象r传入线程里
        //相当于把任务交给了线程
        Thread t = new Thread(r);

        //3 开启线程 会执行Runnable对象里的run方法
        t.start();


        Thread t2 = new Thread(() -> {
            for (int i = 0; i < 100; i++) {
                System.out.println("吃西瓜" + i);
                System.out.println(Thread.currentThread().getName());
            }
        });

        t2.start();

        new Thread(() -> {
            for (int i = 0; i < 100; i++) {
                System.out.println("喝豆浆" + i);
                System.out.println(Thread.currentThread().getName());
            }
        }).start();

两种实现方式的区别

  • 第一种方式:需要自定义类,继承Thread类——子类不能再继承其它类了,比较受限制!
  • 第二种方式:需要自定义类,实现Runnable接口——对于子类更灵活,更方便代码的面向对象设计。

线程小结

在这里插入图片描述

多线程方式三: 实现Callable接口【应用】

  • 方法介绍

    方法名说明
    V call()计算结果,如果无法计算结果,则抛出一个异常
    FutureTask(Callable callable)创建一个 FutureTask,一旦运行就执行给定的 Callable
    V get()如有必要,等待计算完成,然后获取其结果
  • 实现步骤

    • 1定义一个类MyCallable实现Callable接口
    • 2在MyCallable类中重写call()方法
    • 3创建MyCallable类的对象
    • 4创建Future的实现类FutureTask对象,把MyCallable对象作为构造方法的参数
    • 5创建Thread类的对象,把FutureTask对象作为构造方法的参数
    • 6启动线程
    • 7FutureTask对象来调用get方法,就可以获取线程结束之后的结果。

代码 Callable部分

  • 定义一个类MyCallable实现Callable接口
  • 重写call()方法 方法的内容就是要执行的子线程的任务
  • 方法的返回值 可以在子线程结束后 获取
public class MyCallable implements Callable<String> {
    @Override
    public String call() throws Exception {
        for (int i = 0; i < 100; i++) {
            System.out.println("跟女孩表白" + i);
            Thread.sleep(50);
        }
        //返回值就表示线程运行完毕之后的结果
        return "答应";
    }
}

代码 测试部分

  • 创建MyCallable类的对象 mc
  • 创建FutureTask类的对象,把mc作为构造方法的参数传入
  • 创建线程对象
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        //线程开启之后需要执行里面的call方法
        MyCallable mc = new MyCallable();

        //创建FutureTask对象ft 把mc传入,ft可以获取线程执行完毕之后的结果.
        //FutureTask本身实现了Runnable接口
        FutureTask<String> ft = new FutureTask<>(mc);

        //创建线程对象  ft作为参数传递给Thread对象
        Thread t1 = new Thread(ft);
        //System.out.println("1111");
        //String s = ft.get();//代码 阻塞
        //System.out.println("222");
        //开启线程
        t1.start();

        System.out.println("等待表白结果");
        String s = ft.get();
        System.out.println(s);
    }

第三种实现方式可以自己跟一下源码

线程方法回顾

  • 获取线程对象
  • 获取线程名字
  • sleep线程休息

在这里插入图片描述

线程优先级 Priority praɪˈɔːrəti

线程调度(了解)

  • 两种调度方式

    • 分时调度模型:所有线程轮流使用 CPU 的使用权,平均分配每个线程占用 CPU 的时间片
    • 抢占式调度模型:优先让优先级高的线程使用 CPU,如果线程的优先级相同,那么会随机选择一个,优先级高的线程获取的 CPU 时间片相对多一些
  • Java使用的是抢占式调度模型

  • 随机性

    假如计算机只有一个 CPU,那么 CPU 在某一个时刻只能执行一条指令,线程只有得到CPU时间片,也就是使用权,才可以执行指令。所以说多线程程序的执行是有随机性,因为谁抢到CPU的使用权是不一定的

相关方法

方法名说明
final int getPriority()返回此线程的优先级
final void setPriority(int newPriority)更改此线程的优先级线程默认优先级是5;线程优先级的范围是:1-10

代码

  • 注意 优先级大,不一定先执行完,只是增加了抢占cpu的几率
class MyCallable implements Callable<String> {
    @Override
    public String call() throws Exception {
        for (int i = 0; i < 100; i++) {
            System.out.println(Thread.currentThread().getName() + "---" + i);
        }
        return "线程执行完毕了";
    }
}

public class Demo02 {
    public static void main(String[] args) {
        //优先级: 1 - 10 默认值:5
        MyCallable mc = new MyCallable();

        FutureTask<String> ft = new FutureTask<>(mc);

        Thread t1 = new Thread(ft);
        t1.setName("飞机");
        t1.setPriority(10);
        //System.out.println(t1.getPriority());//获取优先级 默认值是5
        t1.start();

        MyCallable mc2 = new MyCallable();

        FutureTask<String> ft2 = new FutureTask<>(mc2);

        Thread t2 = new Thread(ft2);
        t2.setName("坦克");
        t2.setPriority(1);
        //System.out.println(t2.getPriority());//获取优先级 默认值是5
        t2.start();
    }
}

守护线程 Daemon diːmən 滴们

  • 用户线程,jvm会等待用户线程全部结束,最后再结束程序.
  • 守护线程, 当所有用户线程都结束后,由于jvm直接结束程序,守护线程会被直接结束掉
  • 垃圾回收器 就是一个守护线程
  • 应用:一般写 有一些监控功能的需求。 比如定时器

设置的方法

方法名说明
void setDaemon(boolean on)将此线程标记为守护线程,当运行的线程都是守护线程时,Java虚拟机将退出

代码

  • 1代码有两个子线程t1和t2,唱歌和打球,主线程跳舞
  • 2 设置t1和t2为守护线程,那么当用户线程执行完后,如果守护线程任务没有执行完,守护线程也会结束
public class Demo04 {
    public static void main(String[] args) {
        MThread1 t1 = new MThread1();
        //设置为守护线程
        t1.setDaemon(true);

        t1.start();

        MThread2 t2 = new MThread2();
        t2.setDaemon(true);
        t2.start();


        for (int i = 0; i < 100; i++) {
            System.out.println("跳舞" + i);
            try {
                Thread.sleep(10);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        System.out.println("跳完了");
    }
}

class MThread1 extends Thread {
    @Override
    public void run() {
        super.run();
        for (int i = 0; i < 100; i++) {
            System.out.println("唱歌" + i);
            try {
                sleep(50);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        System.out.println("唱完了");
    }
}

class MThread2 extends Thread {
    @Override
    public void run() {
        super.run();
        for (int i = 0; i < 100; i++) {
            System.out.println("打篮球" + i);
            try {
                sleep(70);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        System.out.println("打完了");
    }
}

线程同步 线程安全问题

卖票案例

案例需求

  • 某电影院目前正在上映国产大片,共有100张票,而它有3个窗口卖票,请设计一个程序模拟该电影院卖票

实现步骤

  • 1定义一个类SellTicket实现Runnable接口,里面定义一个成员变量:private int tickets = 100; 表示票的数量
  • 2 在SellTicket类中重写run()方法实现卖票,代码步骤如下
    • 添加死循环,表示一直在买票
    • 判断票数大于0,就卖票,并告知是哪个窗口卖的
    • 卖了票之后,总票数要减1
    • 票数小于等于0,线程停止
  • 3 定义一个测试类SellTicketDemo,里面有main方法,代码步骤如下
    • 创建SellTicket类的对象
    • 创建三个Thread类的对象,给线程定义名字为窗口1、窗口2、窗口3,把SellTicket对象作为构造方法的参数分别传给三个线程对象。
  • 4启动3个线程

代码

  • 注意:
    • 代码中有三个线程对象,Runnable对象只有一个
public class SellTicket implements Runnable {
    private int tickets = 100;
    //在SellTicket类中重写run()方法实现卖票,代码步骤如下
    @Override
    public void run() {
        while (true) {
            if(ticket <= 0){
                    //判断ticket数量小于等于0,说明卖完了,结束循环
                    break;
                }else{
                    try {
                        Thread.sleep(100);//模拟卖票消耗100ms
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    ticket--;//卖票 导致数量-1
                    System.out.println(Thread.currentThread().getName() + "在卖票,还剩下" + ticket + "张票");
                }
        }
    }
}
public class SellTicketDemo {
    public static void main(String[] args) {
        //创建SellTicket类的对象
        SellTicket st = new SellTicket();

        //创建三个Thread类的对象,把SellTicket对象作为构造方法的参数,并给出对应的窗口名称
        Thread t1 = new Thread(st,"窗口1");
        Thread t2 = new Thread(st,"窗口2");
        Thread t3 = new Thread(st,"窗口3");

        //启动线程
        t1.start();
        t2.start();
        t3.start();
    }
}

卖票案例的问题【理解】

  • 卖票出现了问题
    • 相同的票出现了多次
    • 出现了负数的票
  • 问题产生原因
    • 多个线程执行的随机性导致的,可能在卖票过程中丢失cpu的执行权,导致出现问题

1同步代码块解决数据安全问题

  • 安全问题出现的条件
    • 是多线程环境
    • 有共享数据,比如上面案例中的票的数量
    • 有多条语句操作共享数据
  • 如何解决多线程安全问题呢?
    • 基本思想:让程序没有安全问题的环境
  • 怎么实现呢?
    • 把多条语句操作共享数据的代码给锁起来,让任意时刻只能有一个线程执行即可
    • Java提供了同步代码块的方式来解决
  • 同步代码块格式:
synchronized(任意对象) { 
	多条语句操作共享数据的代码 
}
  • synchronized(任意对象):就相当于给代码加锁了,任意对象就可以看成是一把锁
    • 多个线程操作同一个代码块,要保证对象锁是同一个。

代码

  • 注意 是操作共享数据的那块代码 放到同步代码块中
public class SellTicket implements Runnable {
    private int tickets = 100;
    private Object obj = new Object();

    @Override
    public void run() {
        while (true) {
            synchronized (obj) { // 对可能有安全问题的代码加锁,多个线程必须使用同一把锁
                //t1进来后,就会把这段代码给锁起来
                if (tickets > 0) {
                    try {
                        Thread.sleep(100);
                        //t1休息100毫秒
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    //窗口1正在出售第100张票
                    System.out.println(Thread.currentThread().getName() + "正在出售第" + tickets + "张票");
                    tickets--; //tickets = 99;
                }
            }
            //t1出来了,这段代码的锁就被释放了
        }
    }
}

public class SellTicketDemo {
    public static void main(String[] args) {
        SellTicket st = new SellTicket();

        Thread t1 = new Thread(st, "窗口1");
        Thread t2 = new Thread(st, "窗口2");
        Thread t3 = new Thread(st, "窗口3");

        t1.start();
        t2.start();
        t3.start();
    }
}

同步的好处和弊端

  • 好处:解决了多线程的数据安全问题
  • 弊端:当线程很多时,因为每个线程都会去判断同步上的锁,这是很耗费资源的,无形中会降低程序的运行效率
  • 大家可以了解下 hashmap和hashtable的区别

代码的原子性

  • 原子性 :操作要么不间断地全部被执行,不受任何打扰,要么一个也没有执行

  • num++是非原子性操作,本质是3步完成

    • 1获取num的值
    • 2把num的值做+1计算
    • 3 把计算后的值赋值给num
public class Demo02 {
    public static void main(String[] args) {

        A a = new A();

        Thread t4 = new Thread(a);
        Thread t5 = new Thread(a);
        //Thread t6 = new Thread(a);

        t4.start();
        t5.start();
        //t6.start();
    }
}


class A implements Runnable {
    private int num = 0;

    //在SellTicket类中重写run()方法实现卖票,代码步骤如下
    @Override
    public void run() {
        for (int i = 0; i < 100000; i++) {
            synchronized (this) {
                num++;
            }
        }
        System.out.println("num=" + num);
    }
}

图解

在这里插入图片描述

同步方法 解决数据安全问题

同步方法的格式

  • 同步方法:就是把synchronized关键字加到方法上
修饰符 synchronized 返回值类型 方法名(方法参数) { 
	方法体;
}

同步方法的锁对象是什么呢? 是 this

静态同步方法(了解)

  • 同步静态方法:就是把synchronized关键字加到静态方法上
修饰符 static synchronized 返回值类型 方法名(方法参数) { 
	方法体;
}
  • 同步静态方法的锁对象是什么呢? 是类名.class

代码

public class MyRunnable implements Runnable {
    private int ticketCount = 100;

     @Override
    public void run() {
        while (true) {
            //调用sell方法卖票  sell方法是一个同步方法
            boolean isBreak = sell();
            if (isBreak) { //根据sell的返回值 决定是否结束循环
                break;
            }
        }
    }

    public synchronized boolean sell() {
        if (tickets > 0) {
            System.out.println(Thread.currentThread().getName() + "卖出一张电影票");
            try {
                //模拟卖票耗时
                Thread.sleep(10);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            tickets--;
            System.out.println("还剩" + tickets + "张");
            return false;
        } else {
            return true;
        }
    }
}

测试代码

  • 这里两个线程,都行mr对象的里的任务
  • 一个使用同步代码块,一个使用同步方法
    • 这里同步代码块和同步方法的锁都是this,也就是当前的runnable对象mr
public class Demo {

      public static void main(String[] args) {

          MyRunnable mr = new MyRunnable();

          Thread t1 = new Thread(mr);
          Thread t2 = new Thread(mr);
    
          t1.setName("窗口一");
          t2.setName("窗口二");
    
          t1.start();
          t2.start();
      }

  }

演示同步方法的锁是this的代码

  • 下面代码 窗口1线程用同步方法 窗口2线程用同步代码块
  • 同步代码块的锁 只有用this的时候, 最终结果是对象的 ,说明窗口1的同步方法的锁是this
package com.heima.test9;

public class SellTicket implements Runnable {

    //总数量
    private int tickets = 10000;
    Object obj = new Object();
    @Override
    public void run() {
        while (true) {
            //获取线程的名字
            String threadName = Thread.currentThread().getName();
            //判断 是窗口1还是窗口2
            if (threadName.equals("窗口1")) {
                //调用sell方法卖票  sell方法是一个同步方法
                boolean isBreak = sell();
                if (isBreak) { //根据sell的返回值 决定是否结束循环
                    break;
                }
            } else {
                synchronized (this) {
                    if (tickets > 0) {
                        System.out.println(Thread.currentThread().getName() + "卖出一张电影票");
                        //try {
                        //    //模拟卖票耗时
                        //    Thread.sleep(10);
                        //} catch (InterruptedException e) {
                        //    e.printStackTrace();
                        //}
                        tickets--;
                        System.out.println("还剩" + tickets + "张");
                    } else {
                        break;
                    }
                }
            }
        }
    }

    //sell用synchronized修饰 为一个同步方法
    public synchronized boolean sell() {
        if (tickets > 0) {
            System.out.println(Thread.currentThread().getName() + "卖出一张电影票");
            //try {
            //    //模拟卖票耗时
            //    Thread.sleep(10);
            //} catch (InterruptedException e) {
            //    e.printStackTrace();
            //}
            tickets--;
            System.out.println("还剩" + tickets + "张");
            return false;
        } else {
            return true;
        }
    }

}

  • 测试
public static void main(String[] args) {
    SellTicket sellTicket = new SellTicket();

    new Thread(sellTicket,"窗口1").start();
    new Thread(sellTicket,"窗口2").start();
}

Lock锁 Reentrant rɪˈentrənt

  • 虽然我们可以理解同步代码块和同步方法的锁对象问题,但是我们并没有直接看到在哪里加上了锁,在哪里释放了锁,为了更清晰的表达如何加锁和释放锁,JDK5以后提供了一个新的锁对象Lock

  • Lock是接口不能直接实例化,这里采用它的实现类ReentrantLock来实例化

  • ReentrantLock构造方法

    方法名说明
    ReentrantLock()创建一个ReentrantLock的实例
  • 加锁解锁方法

    方法名说明
    void lock()获得锁
    void unlock()释放锁

代码

  • lock.lock()加锁
  • 释放锁lock.unlock(); 一般写在finally中保证正常执行
  public class Ticket implements Runnable {
      //票的数量
      private int ticket = 100;
      private ReentrantLock lock = new ReentrantLock();

      @Override
      public void run() {
          while (true) {
==
              try {
                  lock.lock();//加锁
                  if (ticket <= 0) {
                      //卖完了
                      break;
                  } else {
                      Thread.sleep(100);
                      ticket--;
                      System.out.println(Thread.currentThread().getName() + "在卖票,还剩下" + ticket + "张票");
                  }
              } catch (InterruptedException e) {
                  e.printStackTrace();
              } finally {
                  lock.unlock();//释放锁
              }
          }
      }
  }

  public class Demo {
      public static void main(String[] args) {
          Ticket ticket = new Ticket();

          Thread t1 = new Thread(ticket);
          Thread t2 = new Thread(ticket);
          Thread t3 = new Thread(ticket);

          t1.setName("窗口一");
          t2.setName("窗口二");
          t3.setName("窗口三");

          t1.start();
          t2.start();
          t3.start();
      }
  }

死锁

  • 在一个锁里嵌套添加另外一个锁
  • 当多线程时,导致都卡到两个锁的中间,程序停滞处于等待状态
    public static void main(String[] args) {
        Object objA = new Object();
        Object objB = new Object();

        new Thread(()->{
            while(true){
                synchronized (objA){
                    //线程一
                    System.out.println("小康进入a");
                    synchronized (objB){
                        System.out.println("小康进入b");
                        System.out.println("小康同学正在走路");
                    }
                }
            }
        }).start();

        new Thread(()->{
            while(true){
                synchronized (objB){
                    //线程二
                    System.out.println("小薇进入B");
                    synchronized (objA){
                        System.out.println("小薇进入A");
                        System.out.println("小薇同学正在走路");
                    }
                }
            }
        }).start();
    }

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/133356.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

Pytorch c++ 部署报错解决方案

目录 1. Only the versions between 2017 and 2019 (inclusive) are supported! 2. Cannot find cuDNN library. Turning the option off C 部署的时候&#xff0c;demo 写完之后&#xff0c;提示如下错误 1. Only the versions between 2017 and 2019 (inclusive) are sup…

使用Kubernetes部署xxl-job-admin及xxl-job执行器服务

部署环境 xxl-job-2.4.0kubernetes-1.26 这里以xxl-job官方的2.4.0的代码为例子&#xff0c;在官方编写的Dockerfile基础上使用dockerkubernetes进行部署&#xff0c;xxl-job-admin和执行器的Dockerfile、application等配置文件并不是关键&#xff0c;所以这里示例安装以官方…

Linux系统初始化进程及文件(带命令)

作者简介&#xff1a;一名在校云计算网络运维学生、每天分享网络运维的学习经验、和学习笔记。 座右铭&#xff1a;低头赶路&#xff0c;敬事如仪 个人主页&#xff1a;网络豆的主页​​​​​​ 目录 前言 一.系统初始化进程及文件 1.init 进程 2.Systemd概述 3.SysVi…

【Java语言】— 循环结构 :for循环

循环结构&#xff1a;for循环 1.for循环 控制一段代码反复执行很多次。 for循环的格式如下&#xff1a; for (初始化语句;循环条件;迭代语句){循环体语句(重复执行的代码);}下面我们通过案例&#xff1a;输出3次HelloWorld感受一下。 //需求&#xff1a;输出3次HelloWorld…

OpenOCD 不同仿真器使用操作总结记录

针对不同的仿真器使用 OpenOCD 时候的设置操作总结 ...... 矜辰所致目录前言一、OpenOCD 环境搭建二、OpenOCD 基本测试三、Makefile 中仿真器配置3.1 ST-link3.2 Jlink3.2 CMSIS-DAP&#xff08;待更新&#xff09;结语前言 在使用 GCC 环境开发 ARM 系列芯片的时候&#x…

ArcGIS基础实验操作100例--实验35等高线生成DEM

本实验专栏参考自汤国安教授《地理信息系统基础实验操作100例》一书 实验平台&#xff1a;ArcGIS 10.6 实验数据&#xff1a;请访问实验1&#xff08;传送门&#xff09; 高级编辑篇--实验35 等高线生成DEM 目录 一、实验背景 二、实验数据 三、实验步骤 方法一 &#xff…

4.5、静态路由配置及其可能产生的路由环路问题

静态路由配置是指用户或网络管理员使用路由器的相关命令给路由器人工配置路由表\color{red}人工配置路由表人工配置路由表。 这种人工配置方式简单、开销小。但不能及时适应网络状态&#xff08;流量、拓扑等&#xff09;的变化。\color{red}但不能及时适应网络状态&#xff08…

我的世界Bukkit服务器插件开发教程(十三)资源包与玩家资料

十三、资源包与玩家资料 1.资源包&#xff08;Resource Pack&#xff09; 早期的 Minecraft 并没有资源包一说&#xff0c;而是被叫做材质包。有些服务器为了让玩家拥有更好的游戏体验&#xff0c;一般会在自己特制的客户端中存放一些资源包供玩家加载。 显然&#xff0c;使用…

自动梯度计算

神经网络的参数主要通过梯度下降来进行优化&#xff0e; 当确定了风险函数以及网络结构后&#xff0c; 我们就可以手动用链式法则来计算风险函数对每个参数的梯度&#xff0c; 并用代码进行实现&#xff0e; 但是手动求导并转换为计算机程序的过程非常琐碎并容易出错&#xff0…

二叉树的基础oj题(单值二叉树、相同的树、对称二叉树、二叉树的前序、中序、后序遍历、另一棵树的子树、二叉树的构建和遍历、翻转二叉树)

今天&#xff0c;我带来二叉树的基础oj题 目录单值二叉树&#xff1a;[链接](https://leetcode.cn/problems/univalued-binary-tree/)相同的树&#xff1a;[链接](https://leetcode.cn/problems/same-tree/)对称二叉树&#xff1a;[链接](https://leetcode.cn/problems/symmetr…

syzkaller 黑盒测试1:环境搭建

syzkaller 黑盒测试1&#xff1a;环境搭建 近期需要使用syzkaller对某Linux发行版系统内核进行测试&#xff0c;但是未提供内核源码&#xff0c;只能在黑盒条件下测试。这是笔者第一次接触syzkaller&#xff0c;对测试流程不太熟悉。另外&#xff0c;网上很少有syzkaller黑盒测…

C语言版扫雷——从0到1实现扫雷小游戏

&#x1f412;博客名&#xff1a;平凡的小苏 &#x1f4da;学习格言&#xff1a;有志者&#xff0c;事竟成&#xff0c;破釜沉舟&#xff0c;百二秦关终属楚&#xff1b;苦心人&#xff0c;天不负&#xff0c;卧薪尝胆&#xff0c;三千越甲可吞吴。 扫雷思维导图 目录 扫雷思维…

9_2、Java基本语法之常用类日期、时间类的使用

一、JDK 8之前时间日期API jdk8之前的日期时间类 1.System的currentTimeMillis() 2.java.util.Date以及子类java.sql.Date 3.SimpleDateFormat 4.Calender类&#xff1a;日历类 1、获取系统当前时间&#xff1a;System类下的currentTimeMillis(); //返回的是当前时间与1970年…

MySQL--整合Keepalived进行双机热备自动切换(升级版)

原文网址&#xff1a;MySQL--整合Keepalived进行双机热备自动切换&#xff08;升级版&#xff09;_IT利刃出鞘的博客-CSDN博客 简介 本文介绍MySQL整合Keepalived进行双机热备自动切换&#xff08;升级版&#xff09;。 服务器要考虑高可用问题。nginx、tomcat、缓存、队列、数…

Java开发的古董拍卖系统竞标系统拍卖网

简介 古董展品拍卖网站 用户可以注册成为买家也可以申请开店成为卖家&#xff0c;发布古董展品&#xff0c;设置拍卖起止时间进行展品的拍卖。如果早于拍卖开始时间或者晚于拍卖结束时间&#xff0c;则不可以竞拍。多人竞拍&#xff0c;买家可以根据最高价设置谁中标&#xff…

系分 - 结构化方法【概念】

个人总结&#xff0c;仅供参考&#xff0c;欢迎加好友一起讨论 系分 - &#xff08;概念&#xff09;结构化方法 结构化方法贯穿整个软件工程全部&#xff0c;可以单独细分出来作为某个软件工程环节的技术指引 结构化方法&#xff0c;由结构化分析&#xff08;SA&#xff0c;St…

【C语言进阶】速学,不会用数据库可不能再错过文本与二进制文件操作

目录 ✨前言✨&#xff1a; &#x1f388;一、文本文件与二进制文件&#x1f388;&#xff1a; &#x1f381;二、文件读取结束的判定&#x1f381;&#xff1a; 1.错误使用 feof 函数&#xff1a; 2.判断文件读取结束&#xff1a; &#x1f38a;三、文件缓冲区&#x1f38…

Ubuntu虚拟机图文安装详细教程

Hello, 小伙伴们&#xff0c;大家好&#xff01;今天教大家一步一步进行ubuntu虚拟机的安装。俗话说的好&#xff1a;“工欲善其事必先利其器”&#xff0c;作为一名嵌入式软件开发人员&#xff0c;我们必须熟悉Linux系统的操作及使用&#xff0c;熟练掌握Linux系统下的开发&am…

java 接口的私有方法

其实java8就已经做下伏笔了 在拥有静态和默认 两种拥有方法体的方法之后 接口出现私有方法也是一种必然 然后我们来创建一个包 包下创建一个接口 subInterface 参考代码如下 public interface subInterface {private void show2() {System.out.println("我是一个私有方…

头条权重在线查询,头条号增加权重的4个妙招

头条号权重可以简单理解为头条号指数&#xff0c;刚开通头条号的时候&#xff0c;会根据头条号的领域、介绍等等给予相应的权重。后期会根据账号使用情况进行调整权重&#xff0c;提高或者降低。 头条权重在线查询方法 打开“站长工具”之后&#xff0c;输入网站网址。…