JAVA多线程模式之Balking
2012-02-26 20:48
477 查看
当现在不适合这个操作,或是没有必要进行这个操作时就直接放弃这个操作而回去。这个就是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(); //自动保存}
运行结果:
程序示例:程序的需求是模拟一个自动保存的功能。自动保存是为了预防计算机忽然断电或则软件突然出错的危险,定期将数据保存在文件里的功能。
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(); //自动保存}
运行结果:
相关文章推荐
- JAVA多线程(六)模式-Balking
- Balking Patten ------Java 多线程模式(四)
- JAVA多线程模式之Balking 总结!
- JAVA多线程模式之Balking
- Java 多线程下的单例模式的设计
- java线程安全之多线程的设计模式(十四)
- java多线程之消费者生产者模式
- 单例模式java中的几种写法和确保多线程下安全
- java多线程之Worker Thread模式
- Java基于Socket的简单多线程服务模式
- java多线程12种设计模式
- java集群优化——多线程下的单例模式
- java多线程单例模式
- 消费者模式java多线程之哲学家进餐问题(5人5筷)
- Java多线程编程模式实战指南一:Active Object模式
- java多线程环境单例模式实现详解
- java多线程之消费者生产者模式
- 【Java多线程】多线程之间实现通讯与生产者与消费者模式
- JAVA多线程(三)模式-Single Threaded Execution