重庆分公司,新征程启航

为企业提供网站建设、域名注册、服务器等服务

深入浅析Java中的Balking模式

深入浅析Java中的Balking模式?相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。

原州ssl适用于网站、小程序/APP、API接口等需要进行数据传输应用场景,ssl证书未来市场广阔!成为创新互联公司的ssl证书销售渠道,可以享受市场价格4-6折优惠!如果有意向欢迎电话联系或者加微信:13518219792(备注:SSL证书合作)期待与您的合作!

当现在不适合这个操作,或是没有必要进行这个操作时就直接放弃这个操作而回去。这个就是Balking模式

程序示例:

程序的需求是模拟一个自动保存的功能。自动保存是为了预防计算机忽然断电或则软件突然出错的危险,定期将数据保存在文件里的功能。

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(); //自动保存
  }
}

运行结果:

深入浅析Java中的Balking模式

什么时候使用Balking模式?

1、不需要刻意去执行的时候
2、不想等待警戒条件时
3、警戒条件只有一次成立时

看完上述内容,你们掌握深入浅析Java中的Balking模式的方法了吗?如果还想学到更多技能或想了解更多相关内容,欢迎关注创新互联行业资讯频道,感谢各位的阅读!


分享名称:深入浅析Java中的Balking模式
文章源于:http://cqcxhl.cn/article/joddes.html

其他资讯

在线咨询
服务热线
服务热线:028-86922220
TOP