Java多线程06—用Lock锁解决线程的安全问题

简介: Java多线程06—用Lock锁解决线程的安全问题

解决线程安全问题的方式三:Lock锁

@[toc]

Lock锁

(jdk5.0后的方式)

  • 从JDK 5.0开始,Java提供了更强大的线程同步机制——通过显式定义同 步锁对象来实现同步。同步锁使用Lock对象充当。
  • java.util.concurrent.locks.Lock接口是控制多个线程对共享资源进行访问的 工具。锁提供了对共享资源的独占访问,每次只能有一个线程对Lock对象 加锁,线程开始访问共享资源之前应先获得Lock对象。
  • ReentrantLock 类实现了 Lock ,它拥有与 synchronized 相同的并发性和 内存语义,在实现线程安全的控制中,比较常用的是ReentrantLock,可以 显式加锁、释放锁。
  • 代码举例(实现Runnable接口的方式去创建线程):
package com.jsm.java3;

import java.util.concurrent.locks.ReentrantLock;

/*
解决线程安全问题的方式三:Lock锁,jdk5.0后的方式
例子:创建三个窗口卖票,总票数是100张
 */
public class LockTest2 {
    public static void main(String[] args) {
        Order w1 = new Order();
        Thread t1 = new Thread(w1);
        Thread t2 = new Thread(w1);
        Thread t3 = new Thread(w1);
        t1.start();
        t2.start();
        t3.start();
    }
}

class Order implements Runnable {
    private int num = 100;//未加static,因为此时三个线程共用同一个num,此时只造了一个对象
    //1.实例化ReentrantLock
    private ReentrantLock lock = new ReentrantLock();

    @Override
    public void run() {
        //2.调用锁定方法lock();
        lock.lock();
        try {
            while (true) {
                if (num > 0) {
                    System.out.println(Thread.currentThread().getName() + "卖出的票号为:" + num);
                    num--;
                } else {
                    break;
                }
            }
        } finally{
            //3.调用解锁方法unlock();
            lock.unlock();
        }
    }
}

注意:如果这里用继承Thread的方式去创建线程,lock就得加个static,设置为静态,因为创建了多个对象,要保证lock保证是唯一的

synchronized 与 Lock 的对比

相同点:都是用来解决线程的安全问题

不同点

  • synchronized 机制在执行完相应的同步代码之后,自动的释放同步监视器
  • Lock需要手动的启动同步( .lock() ),同时结束同步也需要手动的实现(unlock() )
优先使用顺序(建议)

Lock —>同步代码块(已经进入了方法体,分配了相应资源) —> 同步方法 (在方法体之外)


练习题

在这里插入图片描述

分析:

  1. 是否是多线程问题?是,两个储户线程
  2. 是否有共享数据吗?有,账户余额
  3. 涉及到线程安全问题吗?是,需要考虑如何解决线程安全问题(同步机制:有三种方式)

答案代码:

package com.jsm.java3;

import com.sun.corba.se.impl.ior.ObjectAdapterIdNumber;

/*
银行有一个账户。
有两个储户分别向同一个账户存3000元,每次存1000,存3次。每次存完打
印账户余额。
 */
public class LXT {
    public static void main(String[] args) {
        Account acct = new Account(0);
        Customer c1 = new Customer(acct);
        Customer c2 = new Customer(acct);

        c1.setName("小明");
        c2.setName("小黄");

        c1.start();
        c2.start();
    }

}
class Account {//账户
    private double balance;//余额

    public Account(double balance) {
        this.balance = balance;
    }

    //存钱
    public void deposit(double amt) {
        synchronized (Account.class) {//解决线程的安全问题
            if (amt > 0) {
                balance += amt;
                System.out.println(Thread.currentThread().getName() + "存钱成功,余额为:" + balance);
            }
        }
    }
}

class Customer extends Thread {//客户
    private Account acct1;

    public Customer(Account acct1) {
        this.acct1 = acct1;
    }

    @Override
    public void run() {
        for (int i = 0; i < 3; i++) {
            acct1.deposit(1000);
        }
    }
}

方式二:

package com.jsm.java3;
/*
银行有一个账户。
有两个储户分别向同一个账户存3000元,每次存1000,存3次。每次存完打
印账户余额。
 */
public class LXT2 {
    public static void main(String[] args) {
        Money m1 = new Money();
        Money m2 = new Money();
        m1.start();
        m2.start();
    }
}
class Money extends Thread {
    private double UserMoney = 3000;
    private static double money = 0;
    @Override
    public void run() {
        while (true) {
            synchronized (Money.class) {
                if (UserMoney>0 ) {
                    UserMoney -= 1000;
                    money += 1000;
                    System.out.println(Thread.currentThread().getName() + "存入1000元,账户余额为:" + money);
                } else {
                    break;
                }
            }
        }
    }
}
.println(Thread.currentThread().getName() + "存入1000元,账户余额为:" + money);
                } else {
                    break;
                }
            }
        }
    }
}
目录
相关文章
|
3月前
|
安全 算法 Java
Java 多线程:线程安全与同步控制的深度解析
本文介绍了 Java 多线程开发的关键技术,涵盖线程的创建与启动、线程安全问题及其解决方案,包括 synchronized 关键字、原子类和线程间通信机制。通过示例代码讲解了多线程编程中的常见问题与优化方法,帮助开发者提升程序性能与稳定性。
143 0
|
4月前
|
Java 数据挖掘 调度
Java 多线程创建零基础入门新手指南:从零开始全面学习多线程创建方法
本文从零基础角度出发,深入浅出地讲解Java多线程的创建方式。内容涵盖继承`Thread`类、实现`Runnable`接口、使用`Callable`和`Future`接口以及线程池的创建与管理等核心知识点。通过代码示例与应用场景分析,帮助读者理解每种方式的特点及适用场景,理论结合实践,轻松掌握Java多线程编程 essentials。
249 5
|
4月前
|
监控 搜索推荐 Java
Java 多线程最新实操技术与应用场景全解析:从基础到进阶
本文深入探讨了Java多线程的现代并发编程技术,涵盖Java 8+新特性,如CompletableFuture异步处理、Stream并行流操作,以及Reactive编程中的Reactor框架。通过具体代码示例,讲解了异步任务组合、并行流优化及响应式编程的核心概念(Flux与Mono)。同时对比了同步、CompletableFuture和Reactor三种实现方式的性能,并总结了最佳实践,帮助开发者构建高效、扩展性强的应用。资源地址:[点击下载](https://pan.quark.cn/s/14fcf913bae6)。
265 3
|
5月前
|
算法 Java 调度
Java多线程基础
本文主要讲解多线程相关知识,分为两部分。第一部分涵盖多线程概念(并发与并行、进程与线程)、Java程序运行原理(JVM启动多线程特性)、实现多线程的两种方式(继承Thread类与实现Runnable接口)及其区别。第二部分涉及线程同步(同步锁的应用场景与代码示例)及线程间通信(wait()与notify()方法的使用)。通过多个Demo代码实例,深入浅出地解析多线程的核心知识点,帮助读者掌握其实现与应用技巧。
102 1
|
5月前
|
Java
java 多线程异常处理
本文介绍了Java中ThreadGroup的异常处理机制,重点讲解UncaughtExceptionHandler的使用。通过示例代码展示了当线程的run()方法抛出未捕获异常时,JVM如何依次查找并调用线程的异常处理器、线程组的uncaughtException方法或默认异常处理器。文章还提供了具体代码和输出结果,帮助理解不同处理器的优先级与执行逻辑。
130 1
|
安全 Java 程序员
Java并发编程中的锁机制与优化策略
【6月更文挑战第17天】在Java并发编程的世界中,锁是维护数据一致性和线程安全的关键。本文将深入探讨Java中的锁机制,包括内置锁、显式锁以及读写锁的原理和使用场景。我们将通过实际案例分析锁的优化策略,如减少锁粒度、使用并发容器以及避免死锁的技巧,旨在帮助开发者提升多线程程序的性能和可靠性。
|
安全 Java 编译器
Java并发编程中的锁优化策略
【5月更文挑战第30天】 在多线程环境下,确保数据的一致性和程序的正确性是至关重要的。Java提供了多种锁机制来管理并发,但不当使用可能导致性能瓶颈或死锁。本文将深入探讨Java中锁的优化策略,包括锁粗化、锁消除、锁降级以及读写锁的使用,以提升并发程序的性能和响应能力。通过实例分析,我们将了解如何在不同场景下选择和应用这些策略,从而在保证线程安全的同时,最小化锁带来的开销。
|
安全 Java 开发者
Java并发编程中的锁优化策略
【5月更文挑战第30天】 在Java并发编程领域,锁机制是实现线程同步的关键手段之一。随着JDK版本的发展,Java虚拟机(JVM)为提高性能和降低延迟,引入了多种锁优化技术。本文将深入探讨Java锁的优化策略,包括偏向锁、轻量级锁以及自旋锁等,旨在帮助开发者更好地理解和应用这些高级特性以提升应用程序的性能。
|
安全 Java
Java并发编程中的锁优化策略
【5月更文挑战第25天】在Java并发编程中,锁是实现线程同步的关键。然而,锁的使用可能导致性能下降,尤其是在高并发场景下。为了提高程序的执行效率,本文将探讨几种常用的锁优化策略,包括自旋锁、适应性锁和锁粗化等技术。通过这些优化策略,我们可以在保证线程安全的同时,提高程序的运行效率。
61 3