新闻中心> 文章详情

南京Java培训机构 Java多线程模式之Balking

2015年06月16日

   当现在不适合这个操作,或是没有必要进行这个操作时就直接放弃这个操作而回去。这个就是Balking模式例如王某在餐厅吃饭,当王某需要点餐时喊服务员需要点餐。当服务员A和B都注意到了王某点餐的示意,这时服务员B看到服务员A已经去响应了王某的点餐请求,所以服务员B就不会再过去响应王某的点餐请求。

 

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

 

  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 { 南京Java培训机构

 

  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;}南京Java培训机构

 

  /** * 保存*/ 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;}南京Java培训机构

 

  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{南京Java培训机构

 

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

 

  友情提示!

 

  南京Java软件开发培训课程详情请访问:http://www.wanho.net/java


上一篇下一篇
按时发顺丰

技术交流群

Java大数据交流群560819979    加入
Python技术交流群595083299    加入
Oracle技术交流群595119011    加入
Web前端技术交流群604697610    加入
Huawei技术交流群482919361    加入
Redhat技术交流群587875348    加入
UI设计技术交流群511649801    加入
Cisco技术交流群596886705    加入
IT运维技术交流群605888381    加入