Java多线程模式之Balking模式 Java多线程模式之Balking模式详解
qq7342272 人气:0想了解Java多线程模式之Balking模式详解的相关内容吗,qq7342272在本文为您仔细讲解Java多线程模式之Balking模式的相关知识和一些Code实例,欢迎阅读和指正,我们先划重点:Java,多线程,Balking,模式,下面大家一起来学习吧。
本文实例讲述了Java多线程模式之Balking模式。分享给大家供大家参考,具体如下:
当现在不适合这个操作,或是没有必要进行这个操作时就直接放弃这个操作而回去。这个就是Balking模式
例如王某在餐厅吃饭,当王某需要点餐时喊服务员需要点餐。当服务员A和B都注意到了王某点餐的示意,这时服务员B看到服务员A已经去响应了王某的点餐请求,所以服务员B就不会再过去响应王某的点餐请求。
程序示例:
程序的需求是模拟一个自动保存的功能。自动保存是为了预防计算机忽然断电或则软件突然出错的危险,定期将数据保存在文件里的功能。
1、Data类:表示是否修改,及修改函数的类
2、SaveThread类:定期保存
3、ChangeThread:修改数据,保存文件
4、Main:模拟数据
package org.zhy.demo04; import java.io.FileWriter; import java.io.IOException; import java.io.Writer; /** * 表示是否修改,及修改函数的类 * @author zhengyi * */ public class Data { private final String fileName; //文件名称 private String content; //修改内容 private boolean changed; //是否可以修改 //构造函数 public Data(String fileName,String content){ this.fileName=fileName; this.content=content; } /** * 新的修改内容 如果有新的需要保存的数据,changed的属性修改为true * 注:这个方法是用synchronized修饰的 * 为了保护content与changed属性用 * synchronized修饰后就只能同时有 * 1个线程访问也就防止了多线程造成的脏数据 * @param newContent */ public synchronized void change(String newContent){ content=newContent; changed=true; } /** * 保存 */ public synchronized void save(){ if(!changed){ //当changed值为false时直接return出去 return ; }else{ doSave();//调用保存方法 changed=false; //保存后changed的值修改为false } } /** * 具体的修改方法,模拟写到文本中。 */ private void doSave(){ System.out.println("线程名称:"+Thread.currentThread().getName()+",最新需要保存的值="+content); try { Writer writer=new FileWriter(fileName); writer.write(content); writer.close(); } catch (IOException e) { e.printStackTrace(); } } }
package org.zhy.demo04; /** * 定期保存的类 * @author zhengyi * */ public class SaveThread extends Thread{ private Data data; public SaveThread(String name,Data data){ super(name);//线程名称 this.data=data; } public void run(){ try { while(true){ data.save(); //模拟保存方法 Thread.sleep(1000); //休息1秒 } } catch (Exception e) { e.printStackTrace(); } } }
package org.zhy.demo04; import java.util.Random; /** * 修改数据,保存文件的类 * @author zhengyi * */ public class ChangeThread extends Thread{ private Data data; private Random random=new Random(); public ChangeThread(String name,Data data){ super(name);//线程名称 this.data=data; } public void run(){ try { for(int i=0;true;i++){ data.change("No:"+i); //模拟的数据 Thread.sleep(random.nextInt(1000)); //模拟去做别的事情 data.save(); //明确的要求要保存 } } catch (Exception e) { e.printStackTrace(); } } }
package org.zhy.demo04; public class Main { public static void main(String[] args) { Data data=new Data("data.txt", "我是默认内容"); //文件的名称及文件的默认内容 new ChangeThread("ChangeThread", data).start(); //手动保存 new SaveThread("SaveThread", data).start(); //自动保存 } }
运行结果:
什么时候使用Balking模式?
1、不需要刻意去执行的时候
2、不想等待警戒条件时
3、警戒条件只有一次成立时
更多java相关内容感兴趣的读者可查看本站专题:《Java数据结构与算法教程》、《Java操作DOM节点技巧总结》、《Java文件与目录操作技巧汇总》和《Java缓存操作技巧汇总》
希望本文所述对大家java程序设计有所帮助。
加载全部内容