JAVA多线程模式之Balking(引)_JAVA_编程开发_程序员俱乐部

中国优秀的程序员网站程序员频道CXYCLUB技术地图
热搜:
更多>>
 
您所在的位置: 程序员俱乐部 > 编程开发 > JAVA > JAVA多线程模式之Balking(引)

JAVA多线程模式之Balking(引)

 2011/12/22 9:21:31  guo583  http://guo583.iteye.com  我要评论(0)
  • 摘要:当现在不适合这个操作,或是没有必要进行这个操作时就直接放弃这个操作而回去。这个就是Balking模式例如王某在餐厅吃饭,当王某需要点餐时喊服务员需要点餐。当服务员A和B都注意到了王某点餐的示意,这时服务员B看到服务员A已经去响应了王某的点餐请求,所以服务员B就不会再过去响应王某的点餐请求。程序示例:程序的需求是模拟一个自动保存的功能。自动保存是为了预防计算机忽然断电或则软件突然出错的危险,定期将数据保存在文件里的功能。1、Data类:表示是否修改,及修改函数的类2、SaveThread类
  • 标签:多线程 Java 模式 线程

当现在不适合这个操作,或是没有必要进行这个操作时就直接放弃这个操作而回去。这个就是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、警戒条件只有一次成立时

发表评论
用户名: 匿名