Java多线程模式之Balking模式详解

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 doShttp://ave(){

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)); //模拟去做别的事http://情

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

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。