脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → java多线程数据安全

Java多线程下解决数据安全问题

 更新时间：2021年08月17日 11:56:49   作者：季沐  
这篇文章主要介绍了Java多线程下解决数据安全问题，本文使用代码进行讲解，可供大家学习参考

同步代码块

基本语句

synchronized (任意对象) {

操作共享代码

}

代码示例

public class SellTicket implements Runnable {
    private int tickets = 100;
    private Object object = new Object();
    @Override
    public void run() {
        while (true) {
            synchronized (object) {
                if (tickets > 0) {
                    try {
                        Thread.sleep(100);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    System.out.println(Thread.currentThread().getName() + "正在出售第" + tickets + "张票");
                    tickets--;
                }
            }
        }
    }
    public static void main(String[] args) {
        SellTicket sellTicket = new SellTicket();
        Thread thread1 = new Thread(sellTicket, "窗口1");
        Thread thread2 = new Thread(sellTicket, "窗口2");
        Thread thread3 = new Thread(sellTicket, "窗口3");
        thread1.start();
        thread2.start();
        thread3.start();
    }
}

优缺点：

  • 解决了多线程的数据安全问题
  • 多线程时，每个线程都会判断同步上的锁，耗费资源，降低了程序的运行效率

同步方法

同步方法：将synchronized关键字加到方法上

  • 格式: 修饰符 synchronized 返回值类型 方法名(){ }
  • 同步方法的锁对象是this

同步静态方法，就是把synchronized关键字加到静态方法上

  • 格式: 修饰符 static synchronized 返回值类型 方法名(){ }
  • 同步静态方法的锁对象是 类名.class

代码示例

public class SellTicket implements Runnable {

//    private int tickets = 100;
    private static int tickets = 100;
    private Object object = new Object();
    private int x = 0;
    @Override
    public void run() {
        while (true) {
            if (x % 2 == 0) {
//                synchronized (object) {
//                synchronized (this) {
                synchronized (SellTicket.class) {
                    if (tickets > 0) {
                        try {
                            Thread.sleep(100);
                        } catch (InterruptedException e) {

                            e.printStackTrace();

                        }                        System.out.println(Thread.currentThread().getName() + "正在出售第" + tickets + "张票");
                        tickets--;
                    }
                }
            } else {
//                synchronized (object) {
//                    if (tickets > 0) {
//                        try {
//                            Thread.sleep(100);
//                        } catch (InterruptedException e) {
//                            e.printStackTrace();
//                        }
//                        System.out.println(Thread.currentThread().getName() + "正在出售第" + tickets + "张票");
//                        tickets--;
//                    }
//                }
                sellTicket();
            }
            x++;
        }
    }
//    private void sellTicket(){
//        synchronized (object) {
//            if (tickets > 0) {
//                try {
//                    Thread.sleep(100);
//                } catch (InterruptedException e) {
//                    e.printStackTrace();
//                }
//                System.out.println(Thread.currentThread().getName() + "正在出售第" + tickets + "张票");
//                tickets--;
//            }
//        }
//    }
//    private synchronized void sellTicket(){
//            if (tickets > 0) {
//                try {
//                    Thread.sleep(100);
//                } catch (InterruptedException e) {
//                    e.printStackTrace();
//                }
//                System.out.println(Thread.currentThread().getName() + "正在出售第" + tickets + "张票");
//                tickets--;
//            }
    private static synchronized void sellTicket(){
        if (tickets > 0) {
            try {
                Thread.sleep(100);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(Thread.currentThread().getName() + "正在出售第" + tickets + "张票");
            tickets--;
        }
    }
    public static void main(String[] args) {
        SellTicket sellTicket = new SellTicket();
        Thread thread1 = new Thread(sellTicket, "窗口1");
        Thread thread2 = new Thread(sellTicket, "窗口2");
        Thread thread3 = new Thread(sellTicket, "窗口3");
        thread1.start();
        thread2.start();
        thread3.start();
    }
}

lock锁

lock实现提供比使用synchronized方法和语句可获得更广泛的操作

  • void lock()获得锁
  • void unlock()释放

lock是接口不能直接实例化，采用实现类实例化ReentrantLock

import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class SellTicket implements Runnable {
    private int tickets = 100;
    private Object object = new Object();
    private Lock lock = new ReentrantLock();
    @Override
    public void run() {
        while (true) {
           try {
                lock.lock();
                if (tickets > 0) {
                    try {
                        Thread.sleep(100);

                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    System.out.println(Thread.currentThread().getName() + "正在出售第" + tickets + "张票");
                    tickets--;
                }
            } finally {
                lock.unlock();
            }
        }
    }
    public static void main(String[] args) {
        SellTicket sellTicket = new SellTicket();
        Thread thread1 = new Thread(sellTicket, "窗口1");
        Thread thread2 = new Thread(sellTicket, "窗口2");
        Thread thread3 = new Thread(sellTicket, "窗口3");
        thread1.start();
        thread2.start();
        thread3.start();
    }

到此这篇关于Java多线程下解决数据安全问题的文章就介绍到这了,更多相关java多线程数据安全内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

相关文章

  • springboot统一返回json数据格式并配置系统异常拦截方式

    springboot统一返回json数据格式并配置系统异常拦截方式

    这篇文章主要介绍了springboot统一返回json数据格式并配置系统异常拦截方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2024-08-08
  • 详解在Java中如何创建多线程程序

    详解在Java中如何创建多线程程序

    今天给大家带来的是关于Java的相关知识,文章围绕着在Java中如何创建多线程程序展开,文中有非常详细的介绍及代码示例,需要的朋友可以参考下
    2021-06-06
  • Java实现批量化操作Excel文件的示例代码

    Java实现批量化操作Excel文件的示例代码

    在操作Excel的场景中,通常会有一些针对Excel的批量操作,这篇文章主要为大家详细介绍了如何使用GcExcel实现批量化操作Excel,感兴趣的可以了解一下
    2024-12-12
  • 详解Java中$符的各种使用场景

    详解Java中$符的各种使用场景

    在Java编程中，我们会经常看到$符的身影，比如经常在配置文件中看到$符号作为变量占位符，用于在运行时动态地获取变量值。本文将详细介绍$符号在Java编程中的各种应用场景，以帮助您更好地理解和运用这个符号，感兴趣的小伙伴可以收藏一下
    2023-04-04
  • java锁机制ReentrantLock源码实例分析

    java锁机制ReentrantLock源码实例分析

    这篇文章主要为大家介绍了java锁机制ReentrantLock源码实例分析，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
    2022-10-10
  • java中字符串常见的方法及总结

    java中字符串常见的方法及总结

    这篇文章主要介绍了java中字符串常见的方法及总结，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2022-12-12
  • 解决springboot 2.x集成log4j2调试日志无法关闭的问题

    解决springboot 2.x集成log4j2调试日志无法关闭的问题

    这篇文章主要介绍了解决springboot 2.x集成log4j2调试日志无法关闭的问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2021-07-07
  • Java中定时器Timer致命缺点案例详解

    Java中定时器Timer致命缺点案例详解

    这篇文章主要介绍了Java中定时器Timer致命缺点，以Java中定时器Time为案例整理下我的学习方法，本文通过实例代码给大家介绍的非常详细,需要的朋友可以参考下
    2022-02-02
  • Mybatis-plus配置分页插件返回统一结果集

    Mybatis-plus配置分页插件返回统一结果集

    本文主要介绍了Mybatis-plus配置分页插件返回统一结果集，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2022-06-06
  • java中的三种取整函数总结

    java中的三种取整函数总结

    下面小编就为大家带来一篇java中的三种取整函数总结。希望对大家有所帮助。一起跟随小编过来看看吧，祝大家游戏愉快哦
    2016-11-11

最新评论