1,线程安全
先看上一节程序,我们稍微改动一下:
//线程安全演示 //火车站有16张票,需要从四个窗口卖出,如果按照上面的多线程实现,程序如下 class Ticket implements Runnable { private int tick = 16;//票的张数---16 public void run(){ while(true){ if(tick>0){ //这里的sleep(100)是这次程序要表的关键,只是个模拟而已 try{ Thread.sleep(100); }catch(Exception e){ } System.out.println(Thread.currentThread().getName() + "...sale:" + tick--); } } } public static void main(String[] args) { Ticket t = new Ticket(); Thread t1 = new Thread(t); Thread t2 = new Thread(t); Thread t3 = new Thread(t); Thread t4 = new Thread(t); t1.start(); t2.start(); t3.start(); t4.start(); } }
其他之处没有改变,只是在判断还有票之后立即睡眠一段时间,这在现实中有可能发生的,线程A刚执行到这里,突然cpu切换到其他线程B中,而B线程也刚好执行到判断语句又被A线程抢夺cpu,此时A线程不用再判断,直接输出,并修改ticket的值,此时有可能使得tickte>0不再满足,但是下一次B线程执行时,也不去判断tickte的值,导致出错。看看上面的程序结果(不为一),数了一下,打印了20张票,还有-1,-2,0的 情况,这就是线程安全问题了。
问题原因:当多条语句在操作同一个线程共享数据时,一个线程对多条语句只执行了一部分,还没有执行完另一个线程就来执行,导致共享数据的错误。
解决办法:对多条操作共享数据的语句,只能让一个线程都执行过程中,其他线程也不能执行。即使其他线程拿到执行权!这就是java提供的同步代码块方案。其格式如下:
synchronized(对象){
需要同步的代码块
}
分析:上面的synchronized后面的对象如同锁,也叫同步监视器,持有锁的线程可以同步执行,没有持有锁的线程即使获取cpu的执行权,也不能进不去同步代码块。线程开始执行同步代码块必须先对同步监视器的锁定。
同步前提:
(1)必须有两个或者两个以上的线程。
(2)必须是多个线程使用同一个锁。
任何时刻只有一个线程获得对同步监视器的锁定,当同步代码块执行结束时,该线程会释放对同步监视器的锁定。
如何看哪些代码需要同步?看看共享数据参与运算的范围。if(tick>0),还有tick—;因此把上面程序改为如下:
//线程安全演示 //火车站有16张票,需要从四个窗口卖出,如果按照上面的多线程实现,程序如下 class Ticket implements Runnable { private int tick = 16;//票的张数---16 Object obj = new Object(); public void run(){ while(true){ synchronized(obj){ if(tick>0){ //这里的sleep(100)是这次程序要表的关键,只是个模拟而已 try{ Thread.sleep(10); }catch(Exception e){ } System.out.println(Thread.currentThread().getName() + "...sale:" + tick--); } } } } public static void main(String[] args) { Ticket t = new Ticket(); Thread t1 = new Thread(t); Thread t2 = new Thread(t); Thread t3 = new Thread(t); Thread t4 = new Thread(t); t1.start(); t2.start(); t3.start(); t4.start(); } }
此时运行就没有出现错误。结果就不展示了。
好处:解决线程安全问题
缺点:多线程需要判断锁,较为消耗资源
2,线程同步
再看下面的例子
/* 需求:银行有一个金库,有两个储户分别存入300元,都是分3次存入 目的:查看该程序是否有安全问题,如果有,如何解决? 如何找问题: 1,明确哪些代码是多线程运行代码 2,明确哪些是共享数据 3,明确哪些代码使用共享数据 */ class Bank { //Object obj = new Object(); ------1 private int sum; public synchronized void add(int n){ //synchronized可以放在此处作为同步函数 //synchronized(obj){ ------2 sum = sum + n; try{ Thread.sleep(10); }catch(Exception e){ } System.out.println("sum = " + sum); //} ------3 } } class Cus implements Runnable { private Bank b = new Bank(); public void run(){ for(int x = 0; x < 3; x++){ b.add(100); } } } class BankDemo { public static void main(String[] agrs){ Cus c = new Cus(); Thread t1 = new Thread(c); Thread t2 = new Thread(c); t1.start(); t2.start(); } }
上面代码如果不同步就会出现线程安全问题,但是同步不止刚才那种同步代码块,还有同步函数可以使用,本程序就是个例子。但是对于卖票那个程序来试试
//线程安全演示 //火车站有16张票,需要从四个窗口卖出,如果按照上面的多线程实现,程序如下 class Ticket implements Runnable { private int tick = 160;//票的张数---160 //Object obj = new Object(); public synchronized void run(){ while(true){ //synchronized(obj){ if(tick>0){ //这里的sleep(1000)是这次程序要表的关键,只是个模拟而已 try{ Thread.sleep(100); }catch(Exception e){ } System.out.println(Thread.currentThread().getName() + "...sale:" + tick--); } //} } } public static void main(String[] args) { Ticket t = new Ticket(); Thread t1 = new Thread(t); Thread t2 = new Thread(t); Thread t3 = new Thread(t); Thread t4 = new Thread(t); t1.start(); t2.start(); t3.start(); t4.start(); } }
结果
其实这里面一直是线程0在执行,因为run方法是在同步,当0线程执行时别的线程都不能执行,这是因为同步的代码块范围不正确,只需要把需要同步的代码块封装为一个函数,便可以在run方法中调用这个函数即可。
//线程安全演示 //火车站有16张票,需要从四个窗口卖出,如果按照上面的多线程实现,程序如下 class Ticket implements Runnable { private int tick = 160;//票的张数 public void run(){ while(true){ show();//此处调用show方法 } } public synchronized void show(){//将同步代码块封装起来 if(tick>0){ try{ Thread.sleep(100); }catch(Exception e){ } System.out.println(Thread.currentThread().getName() + "...sale:" + tick--); } } public static void main(String[] args) { Ticket t = new Ticket(); Thread t1 = new Thread(t); Thread t2 = new Thread(t); Thread t3 = new Thread(t); Thread t4 = new Thread(t); t1.start(); t2.start(); t3.start(); t4.start(); } }
此时可以看到几个线程都启动了。那么有个疑问,同步代码块这种方法有个同步监视器来进行锁住。那么同步方法怎么实现呢?
其实函数都需要对象调用,每个函数都有一个对象引用,就是隐含的this,所以同步函数使用的锁就是this。
通过程序来验证:
使用两个线程来实现卖票,第一个线程在同步函数中,第二个线程在同步代码块中。都在执行卖票动作。
class Ticket implements Runnable { private int tick = 16;//票的张数 Object obj = new Object(); boolean flag = true; public void run(){ if(flag){ while(true){ synchronized(obj){ if(tick>0){ try{ Thread.sleep(100); }catch(Exception e){ } System.out.println(Thread.currentThread().getName() + "...code:" + tick--); } } } } else{ while(true){ show(); } } } public synchronized void show(){ if(tick>0){ try{ Thread.sleep(100); }catch(Exception e){ } System.out.println(Thread.currentThread().getName() + "...show:" + tick--); } } public static void main(String[] args) { Ticket t = new Ticket(); Thread t1 = new Thread(t); Thread t2 = new Thread(t); t1.start(); try{ Thread.sleep(100); }catch(Exception e){ } t.flag = false; t2.start(); } }
结果如下
先来解释一下,这个程序的run()方法中有同步代码块,还有一个同步函数。我们的意思是想让t1先执行,在main函数中让其sleep是因为如果没有sleep的话,主线程可能没有分配给t1的cpu执行权直接执行下面的flag = false这句,导致同步代码块中的代码永远不能执行。加入sleep可以执行同步代码块的代码,也可以执行同步函数中的代码,但是看到结果,打印了0号票,这是不允许的,是什么造成了这种情况?
看看文章最前面的同步的前提,有两个,再次提出:
(1)必须有两个或者两个以上的线程。-----满足
(2)必须是多个线程使用同一个锁。-----不满足-----〉第一个锁是synchronized(obj)中的obj,还有一个同步函数,它的锁是this,就是调用它的对象。
把synchronized(obj)这句换为synchronized(this),就不会出现上述问题,所以这样满足第二个前提,说明同步函数使用的的确是this这个锁。
有个情况,如果同步函数使用static修饰,那么静态方法中的锁是谁呢?肯定不是this,因为静态方法没有this。静态进内存时没有本类对象,但是有本类的字节码对象,该对象的类型是class.因此,对于静态方法,他的同步监视器(也就是锁)就是类名.class。把synchronized(obj)这句换为synchronized(Ticket.class),就不会出现0号票了。
3,死锁
死锁原因:同步中嵌套同步,但是锁却不同步。
先修改上面的程序
class Ticket implements Runnable { private int tick = 1000;//票的张数 Object obj = new Object(); boolean flag = true; public void run(){ if(flag){ while(true){ synchronized(obj){ System.out.println("*****************"); show(); } } } else{ while(true){ System.out.println("------------------"); show(); } } } public synchronized void show(){ synchronized(obj){ if(tick>0){ try{Thread.sleep(10);}catch(Exception e){} System.out.println(Thread.currentThread().getName() + "...code:" + tick--); } } } public static void main(String[] args) { Ticket t = new Ticket(); Thread t1 = new Thread(t); Thread t2 = new Thread(t); t1.start(); try{Thread.sleep(100);}catch(Exception e){} t.flag = false; t2.start(); } }
上面的程序出现死锁,原因是同步代码块中锁是obj,且嵌套同步函数(其锁是this),同步函数的锁是this,而其中又嵌套同步代码块,其锁是obj。可以修改锁即可。比如把obj全部换为this。这样代码就不会出错。但上述代码的输出-----和***之前加入一句判断语句if(tick>0)不然票卖完了还在打印。
上面的例子是同步代码块中包含同步函数,同步函数中又包含同步代码块,下面再看一个只在同步代码块中出现的死锁的例子。
class Test implements Runnable { private boolean flag; Test(boolean flag){ this.flag = flag; } public void run(){ if(flag){ synchronized(MyLock.locka){ System.out.println("if a"); synchronized(MyLock.lockb){ System.out.println("if b"); } } } else{ synchronized(MyLock.lockb){ System.out.println("else b"); synchronized(MyLock.locka){ System.out.println("else a"); } } } } } class MyLock { static Object locka = new Object(); static Object lockb = new Object(); } class DeadLockTest { public static void main(String[] agrs){ Thread t1 = new Thread(new Test(true)); Thread t2 = new Thread(new Test(false)); t1.start(); t2.start(); } }
结合代码,在run()方法中,if语句中的同步代码块有嵌套,else也一样。他们也是这种情况:同步中嵌套同步,但是锁却不同步。
所以在以后的编程过程中一定要防止此类情况的发生。
注:这些代码和相关结论参见毕向东的java基础视频教程和李刚的《疯狂java讲义》,都非常不错!