Java开发——37.多线程_(线程安全)

synchronized(同步监视器){
//需要同步的代码块}
/***   参数说明：*        1.需要被同步的代码：操作共享数据的代码(注意不能多包含代码,也不能少包含代码)；*            共享数据：多个线程共同操作的变量(例如，ticket票号)*        2.同步监视器，俗称：锁。 任何类型的对象都能充当锁*           要求：所有的线程必须保证共享一把锁。*              注意类也是对象(在学习反射的时候会详讲)，可以使用(类名.class)来同步监视器；*                  类只会被加载一次。*              注意使用继承Thread类时 慎用(this)来充当同步监视器；*        解释：(卫生间的锁不能从外面决定关锁/解锁，只能被进卫生间的人从里面关锁/解锁，也就是一个卫生间在同一时间的关锁/解锁只能被一个已经进入卫生间的人操作)。*/

publicclassPraSaleTicket {
publicstaticvoidmain(String[] args) {
Salesale01=newSale();
Salesale02=newSale();
Salesale03=newSale();
sale01.setName("窗口01");
sale02.setName("窗口02");
sale03.setName("窗口03");
sale01.start();
sale02.start();
sale03.start();
    }
}
classSaleextendsThread{
privatestaticintticket=100;
ObjectmyLock=newObject();
@Overridepublicvoidrun() {
//        synchronized (myLock) { // 不能多包含代码，也不能少包含代码while (true){
synchronized (Sale.class) {//当前类为静态类，只能加载一次，所以可以让当前类作为锁if (ticket>0) {
try {
Thread.currentThread().sleep(100);
                    } catch (InterruptedExceptione) {
e.printStackTrace();
                    }
System.out.println(getName() +"_票号为："+ticket);
ticket--;
                } else {
break;
                }
            }
        }
    }
}

publicclassPraSaleTicket_Runnable {
publicstaticvoidmain(String[] args) {
SaleTicketssale=newSaleTickets();
Threadthread=newThread(sale);
Threadthread2=newThread(sale);
Threadthread3=newThread(sale);
thread.setName("窗口01");
thread2.setName("窗口02");
thread3.setName("窗口03");
thread.start();
thread2.start();
thread3.start();
    }
}
classSaleTicketsimplementsRunnable{
privateintticket=100;
//    Object olock = new Object(); // 任何类型的对象都能充当锁。MyLockmyLock=newMyLock();
@Overridepublicvoidrun() {
//    错误的存放位置：Object olock = new Object(); // 任何类型的对象都能充当锁。while (true) {
//    错误的存放位置：Object olock = new Object(); // 任何类型的对象都能充当锁。synchronized(myLock) {
if (ticket>0) {
//如果票号大于0，假设现在票号为1，线程1抢到了CPU，但是还没往后面走，线程2页签到了资源，线程3也抢到了...导致输出的票号出现了:1 0 -1 的现象。//如果此处没有调用sleep()，也会出现重复票号的问题...try {
Thread.currentThread().sleep(100);
                    } catch (InterruptedExceptione) {
e.printStackTrace();
                    }
System.out.println(Thread.currentThread().getName() +"_票号为："+ticket);
ticket--;
                } else {
break;
                }
        }
        }
    }
}
//任何类型的对象都能作为同步监视器。classMyLock{
}

修饰符 (static) synchronized返回值类型方法名(){}

publicclassPraSaleTicket02 {
publicstaticvoidmain(String[] args) {
Salessale01=newSales();
Salessale02=newSales();
Salessale03=newSales();
sale01.setName("窗口01");
sale02.setName("窗口02");
sale03.setName("窗口03");
sale01.start();
sale02.start();
sale03.start();
    }
}
classSalesextendsThread{
privatestaticintticket=100;
@Overridepublicvoidrun() {
while (true){
showTicket();
        }
    }
privatestaticsynchronizedvoidshowTicket(){//默认的同步监视器是当前类(Sales.class)//        private synchronized void showTicket(){ //使用该方法是错的,因为这样是默认传入的同步监视器是this(也就是sale01,sale02,sale03)//不能保证多个线程共用一把锁，所以线程是不安全的。if (ticket>0) {
try {
Thread.currentThread().sleep(100);
            } catch (InterruptedExceptione) {
e.printStackTrace();
            }
System.out.println(Thread.currentThread().getName() +"_票号为："+ticket);
ticket--;
        }
    }
}

publicclassPraSaleTicket_Runnable02 {
publicstaticvoidmain(String[] args) {
SaleTicketsale=newSaleTicket();
Threadthread=newThread(sale);
Threadthread2=newThread(sale);
Threadthread3=newThread(sale);
thread.setName("窗口01");
thread2.setName("窗口02");
thread3.setName("窗口03");
thread.start();
thread2.start();
thread3.start();
    }
}
classSaleTicketimplementsRunnable{
privateintticket=100;
@Overridepublicvoidrun() {
while (true) {
showTickets();
        }
    }
privatesynchronizedvoidshowTickets(){//默认的同步监视器是SaleTicket.classif (ticket>0) {
try {
Thread.currentThread().sleep(100);
            } catch (InterruptedExceptione) {
e.printStackTrace();
            }
System.out.println(Thread.currentThread().getName() +"_票号为："+ticket);
ticket--;
        }
    }