一、任务
创建20个线程,其中10个线程是将数据备份到 A 数据库中,另外10 个线程将数据备份到 B 数据库中,并且备份 A 数据库和 备份 B 数据库的是交叉运行的。
二、实现
/** * Description: 当flag=true的时候备份 A 数据库 * 当flag=false的时候备份 B数据库 以此实现交叉备份 */ public class TaskBackup { volatile private boolean flag=false;// 采用volatile关键字,使变量于多个线程之间可见 synchronized void backupA(){ synchronized 关键字,避免多个线程对同一对象的修改,导致“脏读” try { 记住,这里的判断一定要用while 而不是用if,为什么呢?因为存在多个线程,不止备份B数据库的线程在等待,可能备份A数据库的线程也在等待,如果用if 可能会导致 同类唤醒同类的 情况导致线程的“假死”。 while (flag==false){ this.wait(); } System.out.println(Thread.currentThread().getName()+"正在备份 A 数据库!");//模拟备份数据库 flag=; this.notifyAll();唤醒所有等待的线程,当然这里并不会唤醒backupA 的线程,原因在于,backupA的线程这个时候又做了一个while判断,导致线程继续在等待了,而只有backupB的线程被唤醒了 } catch (InterruptedException e) { e.printStackTrace(); } } void backupB(){ true.wait(); } System.out.println(Thread.currentThread().getName()+"正在备份 B 数据库!");//模拟备份数据库
flag=;
this.notifyAll();
} (InterruptedException e) {
e.printStackTrace();
}
}
}
2、分别创建线程执行 备份任务
class ThreadBackupA extends Thread { private TaskBackup taskPackup; public ThreadBackupA(TaskBackup taskPackup) { this.taskPackup = taskPackup; } @Override run() { super.run(); taskPackup.backupA(); } }
class ThreadBackupB ThreadBackupB(TaskBackup taskPackup) { .run(); taskPackup.backupB(); } }
3、执行任务查看结果
Run { static main(String[] args) { TaskBackup taskPackup=new TaskBackup(); for (int i=0;i<20;i++){ ThreadBackupA threadBackupA= ThreadBackupA(taskPackup); ThreadBackupB threadBackupB= ThreadBackupB(taskPackup); threadBackupA.start(); threadBackupB.start(); } } }
三、结语
觉得这个例子写得特别棒,所以特地记录了一下。它把 诸如 线程notify过程中 wait条件发生改变、同类唤醒同类导致的“假死”问题 等,都做了一个很好的概括应用和解决。笔主资历尚浅,说的不好的地方,还请不吝指教,谢谢!