问题引出
该问题出现分为三个角色
- 门:相当于共享资源
- 用户:相当于一个线程
- 客户端:负责启动多个线程通过这个门
资源在线程使用资源的时候,做了一个检查,检查此时使用资源的名字和地址是否相同
/** * 门,相当于共享资源 */
public class Gate {
private int counter = 0;
private String name = "Nobody";
private String address = "Nowhere";
/** * 通过的方法,相当于使用资源 * @param name * @param address */
public void pass(String name,String address){
this.counter++;
this.name = name;
this.address = address;
verify();
}
/** * 检查 */
private void verify() {
if (this.name.charAt(0)!=this.address.charAt(0)){
System.out.println("*****BROKEN*****"+toString());
}
}
@Override
public String toString() {
return "No." + this.counter + ":" + name + "," + address;
}
}
定义了一个线程,不断的通过这个门,每个线程的名字和地址都能符合检查
/** * 相当于一个线程 */
public class User extends Thread {
private final String myName;
private final String myAddress;
private final Gate gate;
public User(String myName, String myAddress, Gate gate) {
this.myName = myName;
this.myAddress = myAddress;
this.gate = gate;
}
@Override
public void run() {
System.out.println(myName+ " 开始");
while (true){
this.gate.pass(myName,myAddress);//不断的通过门,相当于不断的使用资源
}
}
}
启动多个线程,不断的通过这个门
public class Client {
public static void main(String[] args) {
Gate gate = new Gate();
User u1 = new User("BaoBao","Beijing",gate);
User u2 = new User("ShangLao","Shanghai",gate);
User u3 = new User("GuangLao","Guangzhou",gate);
u1.start();
u2.start();
u3.start();
}
}
结果
GuangLao 开始
BaoBao 开始
*****BROKEN*****No.581:GuangLao,Guangzhou
*****BROKEN*****No.1045:GuangLao,Guangzhou
*****BROKEN*****No.1257:GuangLao,Guangzhou
*****BROKEN*****No.1474:GuangLao,Guangzhou
ShangLao 开始
*****BROKEN*****No.414547:ShangLao,Beijing
- 发现大部分出现问题时
都是不应该出现问题的时候
分析
由于多个线程同时访问共享资源
,在一个线程执行的时候,其他线程对资源进行了更改
解决的方式:在通过的时候加一个this锁
解决
/** * 通过的方法,相当于使用资源 * @param name * @param address */
public synchronized void pass(String name,String address){
this.counter++;
this.name = name;
this.address = address;
verify();
}
- 此时,线程安全的问题得到了解决