美文网首页Java4Android技术文首页推荐
Java多线程之并发安全经典案例-卖票

Java多线程之并发安全经典案例-卖票

作者: 亮之于东 | 来源:发表于2016-10-14 09:10 被阅读626次

    线程相关知识

    1.创建线程的两种方式

    • 继承Thread类。
    • 实现Runnable接口。(这种方式较为常用)

    2.实现Runnable接口的好处

    • 将线程的任务从线程的子类中分离出来,进行了单独的封装。按照面向对象的思想将任务的封装成对象。
    • 避免了java单继承的局限性。

    多线程并发安全之卖票

    • 代码
    
    /**
     * Created by yuandl on 2016-09-30.
     */
    public class RunnableTest implements Runnable {
        private int tick = 60;
    
        @Override
        public void run() {
            while (true) {
                    if (tick == 0) {
                        break;
                    }
                    try {
                        Thread.sleep(10);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    System.out.println(Thread.currentThread().getName() + "=========" + tick--);
            }
        }
        public static void main(String[] args) {
            RunnableTest runnableTest=new RunnableTest();
            new Thread(runnableTest).start();
            new Thread(runnableTest).start();
    
    
        }
    }
    
    
    • 打印结果

    Thread-1=========11
    Thread-1=========10
    Thread-0=========9
    Thread-1=========8
    Thread-0=========7
    Thread-0=========6
    Thread-1=========5
    Thread-0=========4
    Thread-1=========3
    Thread-0=========2
    Thread-1=========1
    Thread-0=========0
    Thread-0=========-1
    Thread-0=========-2
    Thread-0=========-3

    • 发现问题,卖票竟然出现了负数,这肯定是有问题的
    • 线程安全问题产生的原因:
      • 多个线程在操作共享的数据。
      • 操作共享数据的线程代码有多条。
      • 当一个线程在执行操作共享数据的多条代码过程中,其他线程参与了运算。就会导致线程安全问题的产生。
    • 解决思路:
    • 就是将多条操作共享数据的线程代码封装起来,当有线程在执行这些代码的时候,其他线程时不可以参与运算的。必须要当前线程把这些代码都执行完毕后,其他线程才可以参与运算。在java中,用同步代码块就可以解决这个问题。
    • 同步代码块的格式

    synchronized(对象)
    {
    需要被同步的代码 ;
    }

    • 同步的好处:解决了线程的安全问题。
    • 同步的弊端:相对降低了效率,因为同步外的线程的都会判断同步锁。
    • 同步的前提:同步中必须有多个线程并使用同一个锁。

    最终线程安全同步的代码

    
    /**
     * Created by yuandl on 2016-09-30.
     */
    public class RunnableTest implements Runnable {
        private int tick = 60;
    
        @Override
        public void run() {
            while (true) {
                synchronized (this) {
                    if (tick == 0) {
                        break;
                    }
                    try {
                        Thread.sleep(10);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    System.out.println(Thread.currentThread().getName() + "=========" + tick--);
                }
            }
        }
        public static void main(String[] args) {
            RunnableTest runnableTest=new RunnableTest();
            new Thread(runnableTest).start();
            new Thread(runnableTest).start();
        }
    }
    
    • 执行结果

    Thread-1=========10
    Thread-1=========9
    Thread-1=========8
    Thread-1=========7
    Thread-1=========6
    Thread-1=========5
    Thread-1=========4
    Thread-1=========3
    Thread-1=========2
    Thread-1=========1

    Process finished with exit code 0

    完美解决以上问题

    相关文章

      网友评论

      • forDream_12138:例子的代码不好,同步块颗粒度太大,你给的输出,以及我把你代码复制过来,跑了几遍,一直都是一个一个线程在工作。其实已经退化成单线程,没有并发,自然也就没有冲突了。 :sweat:

        第一个冲突的例子中,其实只要把判断条件改成if (tick < 1)就很难出现负数了,要很好的运气才可以发生一次期望的异常结果。
        亮之于东:@forDream_12138 哎,可能是我的代码有问题吧
        forDream_12138:@DylanAndroid E7300的CPU,都是老古董了 还配置高 :sweat: 其实你可以自己跑跑结果看,你的同步块几乎覆盖整个任务周期,模拟的耗时任务Sleep也在同步块以内,此时同步锁并没有释放,第二个线程也是进不来的。就你第二个例子,我用 for 跑了几万次,也没出来过第二个线程工作,也许是我运气太差了 :scream:

        其实方法对的,就是例子的代码不太友好,所以出现了极端结果。
        亮之于东:@forDream_12138 你的电脑配置太高
      • 巴图鲁:不错

      本文标题:Java多线程之并发安全经典案例-卖票

      本文链接:https://www.haomeiwen.com/subject/lwegyttx.html