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

#线程相关知识
1.建立线程的两种方式java

  • 继承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=========-3ide

  • 发现问题,卖票居然出现了负数,这确定是有问题的this

  • 线程安全问题产生的缘由:
    • 多个线程在操做共享的数据。
    • 操做共享数据的线程代码有多条。
    • 当一个线程在执行操做共享数据的多条代码过程当中,其余线程参与了运算。就会致使线程安全问题的产生。
  • 解决思路:
    • 就是将多条操做共享数据的线程代码封装起来,当有线程在执行这些代码的时候,其余线程时不能够参与运算的。必需要当前线程把这些代码都执行完毕后,其余线程才能够参与运算。在java中,用同步代码块就能够解决这个问题。
  • 同步代码块的格式spa

    synchronized(对象)
    {
    须要被同步的代码 ;
    }线程

  • 同步的好处:解决了线程的安全问题。code

  • 同步的弊端:相对下降了效率,由于同步外的线程的都会判断同步锁。
  • 同步的前提:同步中必须有多个线程并使用同一个锁。对象

    #最终线程安全同步的代码

/** * 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

完美解决以上问题

相关文章
相关标签/搜索