Java多线程模式之Balking模式详解

2019-11-26 12:05:08

字体：大中小

来源：转载

供稿：网友

本文实例讲述了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(); //自动保存  }}

运行结果：