线程的同步（协调）synchronized

Posted 2021-01-03 xixixing

多线程同时访问一个数据池时，可能发生冲突，产生异常数据（理解为：多条公路进入同一城市，车辆无序发生混乱）。

使用Runnable接口管理多线程：可以理解为多条公路（线程）通过一个收费站（Runnable接口），达到车辆（run）有序通过的目的。

if条件尽量前置，否则，先执行再判断。

【格式】

synchronized void method(){...} 关键字在方法前，每次只允许一个线程调用此方法

synchronized(Object){...} 关键字在代码块前，每次只允许一个线程调用此代码块

【举例】：通过不同方式购买车票后，查询余票数目。3个线程：手机电脑端、柜台、自助售票机

class MyThreadRunnalbe implements Runnable {
    int num = 10;//车票总数

    public void run() {//线程要执行的任务
        while (true) {
            synchronized (this) {//同步（协调）代码块
                if (num > 0) {//条件尽量前置
                    try {
                        Thread.sleep(500);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    System.out.println(Thread.currentThread().getName() + "购买，余票：" + num--);
                } else break;
            }
        }
    }
}

public class Demo {
    public static void main(String[] args) {
        MyThreadRunnalbe mtr = new MyThreadRunnalbe();//创建端口对象（以下3个线程共同使用这1个端口）
        Thread tA = new Thread(mtr, "手机电脑端");// 以该类对象分别实例化4个线程
        Thread tB = new Thread(mtr, "柜台");
        Thread tC = new Thread(mtr, "自助售票机");
//        //不可以分别new MyThreadRunnalbe()，3个接口使得3个线程各自执行，无法达到有序的目的
//        Thread tA = new Thread(new MyThreadRunnalbe(), "手机电脑端");
//        Thread tB = new Thread(new MyThreadRunnalbe(), "柜台");
//        Thread tC = new Thread(new MyThreadRunnalbe(), "自助售票机");
        tA.start();// 分别启动线程
        tB.start();
        tC.start();
    }
}

 或者，同步（协调）方法sell()

class MyThreadRunnalbe implements Runnable {
    int num = 10;//车票总数

    public void run() {//线程要执行的任务
        while (true) {
            sell();//调用sell方法
            if (num <= 0) break;
        }
    }

    public synchronized void sell() {//创建sell方法，并同步（协调）

        if (num > 0) {//条件尽量前置
            try {
                Thread.sleep(500);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(Thread.currentThread().getName() + "购买，余票：" + num--);
        }
    }
}

public class Demo {
    public static void main(String[] args) {
        MyThreadRunnalbe mtr = new MyThreadRunnalbe();//创建端口对象（以下3个线程共同使用这1个端口）
        Thread tA = new Thread(mtr, "手机电脑端");// 以该类对象分别实例化4个线程
        Thread tB = new Thread(mtr, "柜台");
        Thread tC = new Thread(mtr, "自助售票机");
//        //不可以分别new MyThreadRunnalbe()，3个接口使得3个线程各自执行，无法达到有序的目的
//        Thread tA = new Thread(new MyThreadRunnalbe(), "手机电脑端");
//        Thread tB = new Thread(new MyThreadRunnalbe(), "柜台");
//        Thread tC = new Thread(new MyThreadRunnalbe(), "自助售票机");
        tA.start();// 分别启动线程
        tB.start();
        tC.start();
    }
}