首页 > 编程语言 > 详细

线程的同步(协调)synchronized

时间:2018-09-02 16:02:43      阅读:238      评论:0      收藏:0      [点我收藏+]

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

使用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();
    }
}

 

线程的同步(协调)synchronized

原文:https://www.cnblogs.com/xixixing/p/9574008.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!