问题引出

该问题出现分为三个角色

• 门：相当于共享资源
• 用户：相当于一个线程
• 客户端：负责启动多个线程通过这个门

资源在线程使用资源的时候，做了一个检查，检查此时使用资源的名字和地址是否相同

/** * 门,相当于共享资源 */
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();
}

• 此时，线程安全的问题得到了解决