当现在不适合这个操作,或是没有必要进行这个操作时就直接放弃这个操作而回去。这个就是Balking模式例如王某在餐厅吃饭,当王某需要点餐时喊服务员需要点餐。当服务员A和B都注意到了王某点餐的示意,这时服务员B看到服务员A已经去响应了王某的点餐请求,所以服务员B就不会再过去响应王某的点餐请求。
程序示例:程序的需求是模拟一个自动保存的功能。自动保存是为了预防计算机忽然断电或则软件突然出错的危险,定期将数据保存在文件里的功能。
1、Data类:表示是否修改,及修改函数的类2、SaveThread类:定期保存3、ChangeThread:修改数据,保存文件4、Main:模拟数据
view plainprint?
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();}
}
}
view plainprint?
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();}
view plainprint?
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();}
view plainprint?
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、警戒条件只有一次成立时