wait/notify 实现多线程交叉备份

一、任务

    创建20个线程,其中10个线程是将数据备份到 A 数据库中,另外10 个线程将数据备份到 B 数据库中,并且备份 A 数据库和 备份 B 数据库的是交叉运行的。

二、实现

1、实现备份 A 数据库和备份 B 数据库的 task。

/**
 * Description: 当flag=true的时候备份 A 数据库
 *              当flag=false的时候备份 B数据库 以此实现交叉备份
 */
public class TaskBackup
{
    volatile private boolean flag=false;// 采用volatile关键字,使变量于多个线程之间可见

   synchronized public void backupA(){ //synchronized 关键字,避免多个线程对同一对象的修改,导致“脏读”
        try {
            //记住,这里的判断一定要用while 而不是用if,为什么呢?因为存在多个线程,不止备份B数据库的线程在等待,可能备份A数据库的线程也在等待,如果用if
            //可能会导致 同类唤醒同类的 情况导致线程的“假死”。
            while (flag==false){
                this.wait();
            }
            System.out.println(Thread.currentThread().getName()+"正在备份 A 数据库!");//模拟备份数据库
            flag=false;
            this.notifyAll();//唤醒所有等待的线程,当然这里并不会唤醒backupA 的线程,原因在于,backupA的线程这个时候又做了一个while判断,导致线程继续在等待了,而只有backupB的线程被唤醒了
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    synchronized public void backupB(){
        try {
            while (flag==true){
                this.wait();
            }
            System.out.println(Thread.currentThread().getName()+"正在备份 B 数据库!");//模拟备份数据库

2、分别创建线程执行 备份任务

public class ThreadBackupA extends Thread
{
    private TaskBackup taskPackup;

    public ThreadBackupA(TaskBackup taskPackup)
    {
        this.taskPackup = taskPackup;
    }

    @Override
    public void run()
    {
        super.run();
        taskPackup.backupA();
    }
}
public class ThreadBackupB extends Thread
{
    private TaskBackup taskPackup;

    public ThreadBackupB(TaskBackup taskPackup)
    {
        this.taskPackup = taskPackup;
    }

    @Override
    public void run()
    {
        super.run();
        taskPackup.backupB();
    }
}

3、执行任务查看结果

public class Run
{
    public static void main(String[] args)
    {
        TaskBackup taskPackup=new TaskBackup();
        for (int i=0;i<20;i++){
            ThreadBackupA threadBackupA=new ThreadBackupA(taskPackup);
            ThreadBackupB threadBackupB=new ThreadBackupB(taskPackup);
            threadBackupA.start();
            threadBackupB.start();
        }
    }
}

 三、结语

    觉得这个例子写得特别棒,所以特地记录了一下。它把 诸如 线程notify过程中 wait条件发生改变、同类唤醒同类导致的“假死”问题 等,都做了一个很好的概括应用和解决。笔主资历尚浅,说的不好的地方,还请不吝指教,谢谢!

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏Esofar 开发日记

[译]RabbitMQ教程C#版 - 主题

在 教程[4] 中,我们改进了我们日志系统。我们用direct交换器替换了只能呆滞广播消息的fanout交换器,从而可以有选择性的接收日志。

933
来自专栏葡萄城控件技术团队

Asp.Net MVC4入门指南(2):添加一个控制器

MVC代表: 模型-视图-控制器 。MVC是一个架构良好并且易于测试和易于维护的开发模式。基于MVC模式的应用程序包含: · Models: 表示该应用程序的数...

1927
来自专栏逆向技术

win32进程概念之句柄表,以及内核对象.

我们知道.我们使用CreateProcess 的时候会返回一个进程句柄.以及线程句柄. 其实在调用CreateProcess的时候.内核中会新建一个EPROCE...

882
来自专栏炸天帮5

win32进程概念之句柄表,以及内核对象.

我们知道.我们使用CreateProcess 的时候会返回一个进程句柄.以及线程句柄. 其实在调用CreateProcess的时候.内核中会新建一个EPROCE...

811
来自专栏北京马哥教育

python线程笔记

豌豆贴心提醒,本文阅读时间5分钟 来源:伯乐在线 原文:http://python.jobbole.com/87498/ 引言&动机 考虑一下...

2755
来自专栏Python爬虫与算法进阶

Python函数超时,用装饰器解决

我们在自定义一个函数后,会调用这个函数来完成我们想要的功能。 就拿爬虫来举例,你发送请求,服务器给你响应,但是有可能服务器没有给你任何数据,无论是他识别了爬虫、...

2532
来自专栏PHP实战技术

PHP初级开发者常见的5种疑问

一、文件上传需要注意哪些细节?怎么把文件保存到指定目录?怎么避免上传文件重名问题? 1). 首现要在php.ini中开启文件上传; 2). 在php.ini中有...

3776
来自专栏非著名程序员

Android 混淆从入门到精通

? 简介 作为Android开发者,如果你不想开源你的应用,那么在应用发布前,就需要对代码进行混淆处理,从而让我们代码即使被反编译,也难以阅读。混淆概念虽然容...

3419
来自专栏腾讯移动品质中心TMQ的专栏

运用AOP思想更优雅地进行性能调优

在软件测试中,如果想在一个耗时严重的操作中找出其耗时的瓶颈时,一般采用的方法是在每个被调用的函数中写进测试代码,在运行时打出日志。如果该操作涉及到的业务逻辑特别...

2119
来自专栏向治洪

责任链模式

概述 概念:责任链模式是一种对象的行为模式。在责任链模式里,很多对象由每一个对象对其下家的引用而连接起来形成一条链。请求在这个链上传递,直到链上的某一个对象决定...

1935

扫码关注云+社区

领取腾讯云代金券