一、三大不安全案例
package day02; /*** @Author: Grace* @Date: 2023/10/7 12:50* @Description:*/ //不安全的取钱 //两个人去银行取钱,账户 public class UnsafeBank {public static void main(String[] args) {//账户Account account = new Account(100, "结婚基金"); Drawing you = new Drawing(account, 50, "你");Drawing girlFriend = new Drawing(account, 100, "girlFriend"); you.start();girlFriend.start();} } //账户 class Account{int money;//余额String name;//卡名 public Account(int money, String name) {this.money = money;this.name = name;} } //银行:模拟取款 class Drawing extends Thread{Account account;//账户//取了多少钱int drawingMoney;//现在手里有多少钱int nowMoney;String name; public Drawing(Account account,int drawingMoney,String name){super(name);this.account=account;this.drawingMoney=drawingMoney;} //取钱@Overridepublic void run() {//判断有没有钱if(account.money-drawingMoney<0){System.out.println(Thread.currentThread().getName()+"钱不够,取不了");return;}//sleep放大问题的发生性try {Thread.sleep(100);} catch (InterruptedException e) {throw new RuntimeException(e);}//卡内余额=余额-你取的钱account.money=account.money-drawingMoney;//你手里的钱nowMoney = nowMoney+drawingMoney; System.out.println(account.name+"余额为:"+account.money);//Thread.currentThread().getName()=this.getName();System.out.println(this.getName()+"手里的钱:"+nowMoney);} }
package day02; /*** @Author: Grace* @Date: 2023/10/7 12:41* @Description:*/ //不安全的买票 //线程不安全有负数 public class UnSafeBuyTicket {public static void main(String[] args) {BuyTicket buyTicket = new BuyTicket(); new Thread(buyTicket,"苦逼得我").start();new Thread(buyTicket,"牛逼的你们").start();new Thread(buyTicket,"可恶的黄牛党").start();} } class BuyTicket implements Runnable{ //票private int ticketNums =10;boolean flag = true; //外部停止方式@Overridepublic void run() {//买票while (flag){buy();}}private void buy(){//判断是否有票if(ticketNums<=0){flag=false;return;}//模拟延时try {Thread.sleep(100);} catch (InterruptedException e) {throw new RuntimeException(e);}//买票System.out.println(Thread.currentThread().getName()+"拿到"+ticketNums--);} }
package day02; import java.util.ArrayList; import java.util.List; /*** @Author: Grace* @Date: 2023/10/7 13:07* @Description:*/ //线程不安全的集合 public class UnsafeList {public static void main(String[] args) {List<String> list = new ArrayList<>();for (int i = 0; i < 10000; i++) {new Thread(()->{list.add(Thread.currentThread().getName());}).start();}try {Thread.sleep(3000);} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println(list.size());} }
二、同步方法
-
由于我们可以通过private关键字来保证数据对象只能被方法访问,所以我们只需要针对方法提出一套机制,这套机制就是synchronized关键字,它包括两种用法:synchronized方法和synchronized块
同步方法:public synchronized void method(int args){}
-
synchronized方法控制对“对象”的访问,每个对象对应一把锁,每个synchronized方法都必须获得调用该方法的对象的锁才能执行,否则线程会阻塞,方法一旦执行,就独占该锁,直到该方法返回才释放锁,后面被阻塞的线程才能获得这个锁,继续执行
缺陷:若将一个大的方法申明为synchronized将会影响效率
-
方法里面需要修改的内容才需要锁,锁的太多,浪费资源
三、同步块
-
同步块:synchronized(Obj ){}
-
Obj称之为同步监视器
-
Obj可以是任何对象,但是推荐使用共享资源作为同步监视器
-
同步方法中无需指定同步监视器,因为同步方法的同步监视器就是this,就是这个对象本身,或者是class[反射中讲解]
-
-
同步监视器的执行过程
-
第一个线程访问,锁定同步监视器,执行其中代码
-
第二个线程访问,发现同步监视器被锁定,无法访问
-
第一个线程访问完毕,解锁同步监视器
-
第二个线程访问,发现同步监视器没有锁,然后锁定并访问
-
-
锁的对象就是变化的量,需要增删改的对象
四、CopyOnWriteArrayList
//测试JUC安全类型的集合 public class TestJUC {public static void main(String[] args) {CopyOnWriteArrayList<String> list =new CopyOnWriteArrayList<String>();for (int i = 0; i < 10000; i++) {new Thread(()->{list.add(Thread.currentThread().getName());}).start();} try {Thread.sleep(3000);} catch (InterruptedException e) {throw new RuntimeException(e);} System.out.println(list.size());} }