zoukankan      html  css  js  c++  java
  • Synchronized的各场景使用方法(多窗口售票例子接上篇)


     同步锁机制:
    在《Thinking in Java》中,是这么说的:对于并发工作,你需要某种方式来防
    止两个任务访问相同的资源(其实就是共享资源竞争)。 防止这种冲突的方法
    就是当资源被一个任务使用时,在其上加锁。第一个访问某项资源的任务必须
    锁定这项资源,使其他任务在其被解锁之前,就无法访问它了,而在其被解锁
    之时,另一个任务就可以锁定并使用它了。
     synchronized 的锁是什么 ?
    任意对象都可以作为同步锁。所有对象都自动含有单一的锁(监视器)。
    同步方法的锁:静态方法(类名.class)、非静态方法(this)
    同步代码块:自己指定,很多时候也是指定为this或类名.class
    注意:
    必须确保使用同一个资源的 多个线程共用一把锁,这个非常重要,否则就
    无法保证共享资源的安全
    一个线程类中的所有静态方法共用同一把锁(类名.class),所有非静态方
    法共用同一把锁(this),同步代码块(指定需谨慎)

    使用同步代码块解决继承Thread类的方式的线程安全问题
    package com.atguigu.java;
    
    
    /**
     * 使用同步代码块解决继承Thread类的方式的线程安全问题
     *
     * 例子:创建三个窗口卖票,总票数为100张.使用继承Thread类的方式
     *
     * 说明:在继承Thread类创建多线程的方式中,慎用this充当同步监视器,考虑使用当前类充当同步监视器。
     *
     * @author ch
     * @create 2021-02-13 下午 4:20
     */
    class Window2 extends Thread{
    
    
        private static int ticket = 100;
    
        private static Object obj = new Object();
    
        @Override
        public void run() {
    
            while(true){
                //正确的
    //            synchronized (obj){
                synchronized (Window2.class){//Class clazz = Window2.class,Window2.class只会加载一次
                    //错误的方式:this代表着t1,t2,t3三个对象
    //              synchronized (this){
    
                    if(ticket > 0){
    
                        try {
                            Thread.sleep(100);
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
    
                        System.out.println(getName() + ":卖票,票号为:" + ticket);
                        ticket--;
                    }else{
                        break;
                    }
                }
    
            }
    
        }
    }
    
    
    public class WindowTest2 {
        public static void main(String[] args) {
            Window2 t1 = new Window2();
            Window2 t2 = new Window2();
            Window2 t3 = new Window2();
    
    
            t1.setName("窗口1");
            t2.setName("窗口2");
            t3.setName("窗口3");
    
            t1.start();
            t2.start();
            t3.start();
    
        }
    }
    使用同步方法解决实现Runnable接口的线程安全问题
    
    
    package com.atguigu.java;
    
    /**
     * 使用同步方法解决实现Runnable接口的线程安全问题
     *
     *
     *  关于同步方法的总结:
     *  1. 同步方法仍然涉及到同步监视器,只是不需要我们显式的声明。
     *  2. 非静态的同步方法,同步监视器是:this
     *     静态的同步方法,同步监视器是:当前类本身
     *
     * @author ch
     * @create 2021-02-15 上午 11:35
     */
    
    
    class Window3 implements Runnable {
    
        private int ticket = 100;
    
        @Override
        public void run() {
            while (true) {
    
                show();
            }
        }
    
        private synchronized void show(){//同步监视器:this
            //synchronized (this){
    
                if (ticket > 0) {
    
                    try {
                        Thread.sleep(100);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
    
                    System.out.println(Thread.currentThread().getName() + ":卖票,票号为:" + ticket);
    
                    ticket--;
                }
            //}
        }
    }
    
    
    public class WindowTest3 {
        public static void main(String[] args) {
            Window3 w = new Window3();
    
            Thread t1 = new Thread(w);
            Thread t2 = new Thread(w);
            Thread t3 = new Thread(w);
    
            t1.setName("窗口1");
            t2.setName("窗口2");
            t3.setName("窗口3");
    
            t1.start();
            t2.start();
            t3.start();
        }
    
    }
    
    
    使用同步方法处理继承Thread类的方式中的线程安全问题
    
    
    package com.atguigu.java;
    
    /**
     * 使用同步方法处理继承Thread类的方式中的线程安全问题
     *
     * @author ch
     * @create 2021-02-15 上午 11:43
     */
    class Window4 extends Thread {
    
    
        private static int ticket = 100;
    
        @Override
        public void run() {
    
            while (true) {
    
                show();
            }
    
        }
        private static synchronized void show(){//同步监视器:Window4.class
            //private synchronized void show(){ //同步监视器:t1,t2,t3。此种解决方式是错误的
            if (ticket > 0) {
    
                try {
                    Thread.sleep(100);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
    
                System.out.println(Thread.currentThread().getName() + ":卖票,票号为:" + ticket);
                ticket--;
            }
        }
    }
    
    
    public class WindowTest4 {
        public static void main(String[] args) {
            Window4 t1 = new Window4();
            Window4 t2 = new Window4();
            Window4 t3 = new Window4();
    
    
            t1.setName("窗口1");
            t2.setName("窗口2");
            t3.setName("窗口3");
    
            t1.start();
            t2.start();
            t3.start();
    
        }
    }
    使用同步方法解决实现Runnable接口的线程安全问题
    /**
     * 使用同步方法解决实现Runnable接口的线程安全问题
     *
     *
     *  关于同步方法的总结:
     *  1. 同步方法仍然涉及到同步监视器,只是不需要我们显式的声明。
     *  2. 非静态的同步方法,同步监视器是:this
     *     静态的同步方法,同步监视器是:当前类本身
     *
     * @author CH
     * @create 2021-02-15 上午 11:35
     */
    
    
    class Window3 implements Runnable {
    
        private int ticket = 100;
    
        @Override
        public void run() {
            while (true) {
    
                show();
            }
        }
    
        private synchronized void show(){//同步监视器:this
            //synchronized (this){
    
                if (ticket > 0) {
    
                    try {
                        Thread.sleep(100);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
    
                    System.out.println(Thread.currentThread().getName() + ":卖票,票号为:" + ticket);
    
                    ticket--;
                }
            //}
        }
    }
    
    
    public class WindowTest3 {
        public static void main(String[] args) {
            Window3 w = new Window3();
    
            Thread t1 = new Thread(w);
            Thread t2 = new Thread(w);
            Thread t3 = new Thread(w);
    
            t1.setName("窗口1");
            t2.setName("窗口2");
            t3.setName("窗口3");
    
            t1.start();
            t2.start();
            t3.start();
        }
    
    }







     

     
    不积跬步,无以至千里;不积小流,无以成江海。
  • 相关阅读:
    Chrome浏览器扩展开发系列之十四:本地消息机制Native messaging
    Chrome浏览器扩展开发系列之十三:消息传递Message
    Chrome浏览器扩展开发系列之十二:Content Scripts
    Chrome浏览器扩展开发系列之十一:NPAPI插件的使用
    Chrome浏览器扩展开发系列之十:桌面通知Notification
    《转载》使用CSS3 Flexbox布局
    CSS display属性的值及作用
    CSS中的各种居中方法总结
    《转载》详解 CSS 属性
    CSS3中新增的内容
  • 原文地址:https://www.cnblogs.com/CCTVCHCH/p/14646311.html
Copyright © 2011-2022 走看看