package com.aff.thread;

/*

    使用实现Runnable接口的方式，售票

    存在线程安全问题：  打印车票时出现重票，错票

    1.原因：由于一个线程在操作共享数据过程中，未执行完毕的情况下，

           另外的线程参与进来了，导致共享数据存在了安全问题

    2.解决想法：让一个线程操作共享数据完毕后，其他进程才有机会参与共享数据的使用

    3.java的解决方案：

               线程的同步机制

                        方式一：同步代码块

                                                    synchronized(同步监视器){

                                                       //需要被同步的代码块(即为操作共享数据的代码)

                                                     }

                                            1.共享数据：多个线程共同操作的同一个数据(变量)

                                            2.同步监视器：由一个类的对象来充当，哪个线程获取此监视器，

                                              谁就执行大括号里被同步的代码，俗称 "锁"

                                            3.要求所有线程必须共用同一把锁

                                      注意： 在实现的方式中，考虑同步的话，可以使用this充当锁。

                                            但是在继承的方式中，慎用this

                        方式二：同步方法

                                            将操作共享数据的方法声明为synchronized,
                                            即此方法为同步方法，

                                            能够保证当其中一个线程执行此方法时，
                                            其他线程在外等待直至此线程执行完此方法。

                                       注意：同步方法的锁为this

    4.线程的同步的弊端：由于同一个时间只能有一个线程访问共享数据，效率变低了                         

*/

public class TestWindow2 {

    public static void main(String[] args) {

        Window2 w = new Window2();

        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();

    }

}

class Window2 implements Runnable {

    int ticket = 100;// 共享数据

    //Object obj = new Object();

    @Override

    public void run() {

        while (true) {

            synchronized (this){//任何一个类的对象都可以来充当 ，习惯上使用this充当，指当前的对象，
                                //此处指的是w对象，若换成继承的方式实现多线程，
                                //那此处的this分别指的三个对象了,不是同一把锁,就解决不了安全性问题了

                if (ticket > 0) {

                    try {

                        Thread.currentThread().sleep(10);

                    } catch (InterruptedException e) {

                        e.printStackTrace();

                    }

                    System.out.println(Thread.currentThread().getName() + "售票，票号为：" + ticket--);

                }

            }

        }

    }

}

package com.aff.thread;

public class TestWindow4 {

    public static void main(String[] args) {

        Window4 w = new Window4();

        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();

    }

}

class Window4 implements Runnable {

    int ticket = 1000;// 共享数据

    @Override

    public void run() {

        while (true) {

            show();

        }

    }

    public synchronized void show() {

        if (ticket > 0) {

            try {

                Thread.currentThread().sleep(10);

            } catch (InterruptedException e) {

                e.printStackTrace();

            }

            System.out.println(Thread.currentThread().getName() + "售票，票号为：" + ticket--);

        }

    }

}