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程序设计有所帮助。