Java学习之线程间通信（双线程）

线程间通讯：多个线程在处理同一资源，但是任务不同

练习一：双线程出现线程安全问题，需要使用同步，思考同步代码添加位置
需求：银行账户存钱，显示谁在账户存钱了，存了多少钱
分析：
操作同一银行账户
两个不同的操作，一个是存，一个是显示
这个两个操作可以同时执行

代码：

class Bank
{
    String name;//存钱人名
    int amount;
    
    //无论是存还是取应该都是银行的动作
    void put(String name,int amount)
    {
        this.name=name;
        this.amount=amount;
    }
    
    void take()
    {
        System.out.println(this.name+"---"+this.amount);
    }
}
//定义对象实现Runnable,设置线程任务
class Input implements Runnable
{
    private Bank b;
    //使用构造函数保证存钱和显示同一资源
    public Input(Bank b)
    {
        this.b=b;
    }
    public void run()
    {
        int x=0;
        while(true)
        {
            if(x==0)
            {
                b.put("张三",100);
            }
            else
            {
                b.put("lisi",200);
            }
            //0与1之间切换可使用求2的余数
            x=(x+1)%2;
        }
    }
}

//定义对象实现Runnable,设置线程任务
class Output implements Runnable
{
    private Bank b;
    //使用构造函数保证存钱和显示同一资源
    public Output(Bank b)
    {
        this.b=b;
    }
    public void run()
    {
        while(true)
        {
            b.take();
        }
    }
}

class ThreadDemo
{
    public static void main (String[] args)
    {
        //同一资源
        Bank b=new Bank();
        
        Input in=new Input(b);
        Output out=new Output(b);
        
        //
        Thread t1=new Thread(in);
        Thread t2=new Thread(out);
        
        t1.start();
        t2.start();
    }
}

结果：

出现线程安全，为什么呢？

分析：

 解决方法：添加同步（synchronized），同步要添加到什么位置？

添加同步锁的原则：有共享数据被操作的代码上，且同步锁对象要相同（同步方法的同步锁为，此类的对象（this））

代码：

class Bank
{
    String name;//存钱人名
    int amount;
    
    //同步方法的同步锁为，此类的对象（this）
    synchronized void put(String name,int amount)
    {
        this.name=name;
        this.amount=amount;
    }
    
    synchronized void take()
    {
        System.out.println(this.name+"---"+this.amount);
    }
}

结果出现的效果与预想结果不同，预想结果是存一笔，显示一笔：

结果分析：

 接下来，想法是：在t1中执行完成后就让t2执行

具体做法：

1、使用一个共享数据（flag）记录t1是否已执行

2、已执行就让t1等待（原因：防止t1再次获取CPU执行权），让t2执行

3、t2执行完成，t2等待，把t1设置成未执行状态（让t1获取CPU执行资格）

class Bank
{
    private String name;
    private int amount;
    private boolean flag=false;
    
    synchronized void put(String name,int amount)
    {
        //1、判断线程是否已执行，防止t1线程多次获取CUP执行权
        if(flag)
            try{this.wait();}catch(InterruptedException e){}//wait()方法，将线程存放在阻塞线程池中，释放CUP执行权和释放同步锁
            
        this.name=name;
        this.amount=amount;
        //已执行赋值
        this.flag = true;
        //唤醒阻塞线程池中的任意一个线程，获取CUP执行资格
        this.notify();
    }
    
    synchronized void take()
    {
        if(!flag)
            try{this.wait();}catch(InterruptedException e){}
        System.out.println(this.name+"---"+this.amount);
        
        this.flag = false;
        this.notify();
    }
}

结果：